Use kwarg to specify connection.

This commit is contained in:
Vincent Driessen 2013-12-07 13:33:15 +01:00
parent 1792a194bd
commit 9abbfc4dfb
1 changed files with 1 additions and 1 deletions

View File

@ -310,7 +310,7 @@ class Worker(object):
except StopRequested: except StopRequested:
break break
except UnpickleError as e: except UnpickleError as e:
job = Job.safe_fetch(e.job_id, self.connection) job = Job.safe_fetch(e.job_id, connection=self.connection)
self.handle_exception(job, *sys.exc_info()) self.handle_exception(job, *sys.exc_info())
continue continue