diff --git a/rq/worker.py b/rq/worker.py index 67a2bed..d527957 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -250,8 +250,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. '