Merge pull request #494 from ta2-1/master

Add missed `multi` command after `watch`
10 years ago · 09b08e46ce
parent 5bcca82ea4 3dfd044767
commit 09b08e46ce
1 changed files with 1 additions and 0 deletions
--- 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)