From d0381e98ee84e673d397d0cad06cb39c369ad12d Mon Sep 17 00:00:00 2001 From: Vincent Driessen Date: Thu, 23 Jan 2014 10:40:29 +0100 Subject: [PATCH] Fix .pipeline -> ._pipeline. This makes sure it's compatible with both Redis and StrictRedis back ends. --- rq/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index 69aac70..aea05a1 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -416,7 +416,7 @@ class Worker(object): job.func_name, job.origin, time.time())) - with self.connection.pipeline() as pipeline: + with self.connection._pipeline() as pipeline: try: with death_penalty_after(job.timeout or Queue.DEFAULT_TIMEOUT): rv = job.perform()