Fix .pipeline -> ._pipeline.

This makes sure it's compatible with both Redis and StrictRedis back
ends.
main
Vincent Driessen 11 years ago
parent fd036538f7
commit d0381e98ee

@ -416,7 +416,7 @@ class Worker(object):
job.func_name, job.func_name,
job.origin, time.time())) job.origin, time.time()))
with self.connection.pipeline() as pipeline: with self.connection._pipeline() as pipeline:
try: try:
with death_penalty_after(job.timeout or Queue.DEFAULT_TIMEOUT): with death_penalty_after(job.timeout or Queue.DEFAULT_TIMEOUT):
rv = job.perform() rv = job.perform()

Loading…
Cancel
Save