Rename function

bleachzk · Jul 24, 2016 · 14d8783 · 14d8783
1 parent 94d5cae
commit 14d8783
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/rq/worker.py b/rq/worker.py
@@ -530,7 +530,7 @@ def monitor_work_horse(self, job):
                         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 @@ def prepare_job_execution(self, job):
         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 @@ def perform_job(self, job, queue):
                 pipeline.execute()
 
             except Exception:
-                self.handle_current_job_failure(
+                self.handle_job_failure(
                     job=job,
                     started_job_registry=started_job_registry,
                     pipeline=pipeline