Should pass a connection here because we might not be using a connection stack.

main
Malthe Borch 11 years ago
parent 09d461c2c0
commit 1792a194bd

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

Loading…
Cancel
Save