From 3dfd044767706ff6e2d0169a13d237d66e1154a6 Mon Sep 17 00:00:00 2001 From: Taras Semenenko Date: Wed, 25 Feb 2015 14:32:37 +0300 Subject: [PATCH] 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 --- rq/queue.py | 1 + 1 file changed, 1 insertion(+) diff --git a/rq/queue.py b/rq/queue.py index 988a54e..f5a8887 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -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)