From 2044e790f5989f0dc45b2c285ec8bdba1b6b96be Mon Sep 17 00:00:00 2001 From: Selwin Ong Date: Mon, 10 Feb 2014 22:19:23 +0700 Subject: [PATCH] Renamed Worker.fork_and_perform_job to Worker.execute_job. --- rq/worker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rq/worker.py b/rq/worker.py index aea05a1..c9faa7e 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -318,7 +318,7 @@ class Worker(object): blue(job.description), job.id)) self.heartbeat((job.timeout or 180) + 60) - self.fork_and_perform_job(job) + self.execute_job(job) self.heartbeat() if job.status == Status.FINISHED: queue.enqueue_dependents(job) @@ -359,7 +359,7 @@ class Worker(object): self.log.debug('Sent heartbeat to prevent worker timeout. ' 'Next one should arrive within {0} seconds.'.format(timeout)) - def fork_and_perform_job(self, job): + def execute_job(self, job): """Spawns a work horse to perform the actual work and passes it a job. The worker will wait for the work horse and make sure it executes within the given timeout bounds, or will end the work horse with