From 933e6697cd0ac5d4037eed5e14d07daf312e4086 Mon Sep 17 00:00:00 2001 From: Vlad Pronsky Date: Thu, 5 Mar 2015 01:08:07 +0200 Subject: [PATCH] Fixed redis drivers bug --- rq/queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/queue.py b/rq/queue.py index f5a8887..ea39d81 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -194,7 +194,7 @@ class Queue(object): if depends_on is not None: if not isinstance(depends_on, self.job_class): depends_on = Job(id=depends_on, connection=self.connection) - with self.connection.pipeline() as pipe: + with self.connection._pipeline() as pipe: while True: try: pipe.watch(depends_on.key)