From 14d87832120a4f0f648668e86cc190739b271c33 Mon Sep 17 00:00:00 2001 From: Yannis Spiliopoulos Date: Sun, 24 Jul 2016 09:23:31 -0400 Subject: [PATCH] Rename function --- rq/worker.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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