Initial work towards the celery refactor... adjusting logic to allow building a worker chain... temporarily relax requirements on status checks

This commit is contained in:
Matthew Jones 2014-01-27 11:37:18 -05:00
parent 2e45ad1a63
commit 5c076529c0

View File

@ -343,7 +343,6 @@ class Job(CommonTask):
opts = dict([(field, kwargs.get(field, '')) for field in needed])
if not all(opts.values()):
return False
# TODO: This is temporary to allow a dependent task to continue
self.status = 'waiting'
self.save(update_fields=['status'])
transaction.commit()