Add missed `multi` command after `watch`

`watch` command should be used in conjunction with `multi` command
which was missed in enqueuing of job with dependencies.
Fix #487
main
Taras Semenenko 10 years ago
parent 5bcca82ea4
commit 3dfd044767

@ -199,6 +199,7 @@ class Queue(object):
try:
pipe.watch(depends_on.key)
if depends_on.get_status() != JobStatus.FINISHED:
pipe.multi()
job.set_status(JobStatus.DEFERRED)
job.register_dependency(pipeline=pipe)
job.save(pipeline=pipe)

Loading…
Cancel
Save