|
@@ -129,7 +129,6 @@ class Job(models.Model):
|
|
|
data = models.TextField(blank=True, default=json.dumps({})) # e.g. data=json.dumps({'sla': [python data], ...})
|
|
data = models.TextField(blank=True, default=json.dumps({})) # e.g. data=json.dumps({'sla': [python data], ...})
|
|
|
|
|
|
|
|
objects = JobManager()
|
|
objects = JobManager()
|
|
|
- unique_together = ('owner', 'name')
|
|
|
|
|
|
|
|
|
|
def delete(self, skip_trash=False, *args, **kwargs):
|
|
def delete(self, skip_trash=False, *args, **kwargs):
|
|
|
if skip_trash:
|
|
if skip_trash:
|
|
@@ -643,8 +642,6 @@ class Node(models.Model):
|
|
|
children = models.ManyToManyField('self', related_name='parents', symmetrical=False, through=Link)
|
|
children = models.ManyToManyField('self', related_name='parents', symmetrical=False, through=Link)
|
|
|
data = models.TextField(blank=True, default=json.dumps({}))
|
|
data = models.TextField(blank=True, default=json.dumps({}))
|
|
|
|
|
|
|
|
- unique_together = ('workflow', 'name')
|
|
|
|
|
-
|
|
|
|
|
def get_full_node(self):
|
|
def get_full_node(self):
|
|
|
if self.node_type == Mapreduce.node_type:
|
|
if self.node_type == Mapreduce.node_type:
|
|
|
node = self.mapreduce
|
|
node = self.mapreduce
|
|
@@ -1677,7 +1674,6 @@ class Dataset(models.Model):
|
|
|
help_text=_t('Optional: Shift the frequency for gettting past/future end dates or enter verbatim the Oozie end instance.'))
|
|
help_text=_t('Optional: Shift the frequency for gettting past/future end dates or enter verbatim the Oozie end instance.'))
|
|
|
|
|
|
|
|
objects = DatasetManager()
|
|
objects = DatasetManager()
|
|
|
- unique_together = ('coordinator', 'name')
|
|
|
|
|
|
|
|
|
|
def __unicode__(self):
|
|
def __unicode__(self):
|
|
|
return '%s' % (self.name,)
|
|
return '%s' % (self.name,)
|
|
@@ -1731,8 +1727,6 @@ class DataInput(models.Model):
|
|
|
help_text=_t('The pattern of the input data we want to process.'))
|
|
help_text=_t('The pattern of the input data we want to process.'))
|
|
|
coordinator = models.ForeignKey(Coordinator)
|
|
coordinator = models.ForeignKey(Coordinator)
|
|
|
|
|
|
|
|
- unique_together = ('coordinator', 'name')
|
|
|
|
|
-
|
|
|
|
|
|
|
|
|
|
class DataOutput(models.Model):
|
|
class DataOutput(models.Model):
|
|
|
name = models.CharField(max_length=40, validators=[name_validator], verbose_name=_t('Name of an output variable in the workflow'),
|
|
name = models.CharField(max_length=40, validators=[name_validator], verbose_name=_t('Name of an output variable in the workflow'),
|
|
@@ -1741,8 +1735,6 @@ class DataOutput(models.Model):
|
|
|
help_text=_t('The pattern of the output data we want to generate.'))
|
|
help_text=_t('The pattern of the output data we want to generate.'))
|
|
|
coordinator = models.ForeignKey(Coordinator)
|
|
coordinator = models.ForeignKey(Coordinator)
|
|
|
|
|
|
|
|
- unique_together = ('coordinator', 'name')
|
|
|
|
|
-
|
|
|
|
|
|
|
|
|
|
class BundledCoordinator(models.Model):
|
|
class BundledCoordinator(models.Model):
|
|
|
bundle = models.ForeignKey('Bundle', verbose_name=_t('Bundle'),
|
|
bundle = models.ForeignKey('Bundle', verbose_name=_t('Bundle'),
|