Merge branch 'malthe-fix-safe-fetch-connection-error'

11 years ago · 39ce12f9c3
parent 09d461c2c0 9abbfc4dfb
commit 39ce12f9c3
1 changed files with 1 additions and 1 deletions
--- a/rq/worker.py
+++ b/rq/worker.py
@ -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, connection=self.connection)
                    self.handle_exception(job, *sys.exc_info())
                    continue