diff --git a/rq/worker.py b/rq/worker.py index 2be8aae..3306be6 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -249,8 +249,9 @@ class Worker(object): msg = 'Warm shut down requested.' self.log.warning(msg) - # If shutdown is requested in the middle of a job, wait until finish - # before shutting down + + # If shutdown is requested in the middle of a job, wait until + # finish before shutting down if self.state == 'busy': self._stopped = True self.log.debug('Stopping after current horse is finished. '