diff --git a/rq/worker.py b/rq/worker.py index 952ad0c..fd55b44 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -530,7 +530,7 @@ class Worker(object): break if job_status not in [JobStatus.FINISHED, JobStatus.FAILED]: with self.connection._pipeline() as pipeline: - self.handle_current_job_failure( + self.handle_job_failure( job=job, pipeline=pipeline ) @@ -611,7 +611,7 @@ class Worker(object): msg = 'Processing {0} from {1} since {2}' self.procline(msg.format(job.func_name, job.origin, time.time())) - def handle_current_job_failure( + def handle_job_failure( self, job, started_job_registry=None, @@ -672,7 +672,7 @@ class Worker(object): pipeline.execute() except Exception: - self.handle_current_job_failure( + self.handle_job_failure( job=job, started_job_registry=started_job_registry, pipeline=pipeline