|
|
@ -466,8 +466,6 @@ class Worker(object):
|
|
|
|
if burst:
|
|
|
|
if burst:
|
|
|
|
self.log.info("RQ worker {0!r} done, quitting".format(self.key))
|
|
|
|
self.log.info("RQ worker {0!r} done, quitting".format(self.key))
|
|
|
|
break
|
|
|
|
break
|
|
|
|
except StopRequested:
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
job, queue = result
|
|
|
|
job, queue = result
|
|
|
|
self.execute_job(job, queue)
|
|
|
|
self.execute_job(job, queue)
|
|
|
@ -475,6 +473,8 @@ class Worker(object):
|
|
|
|
|
|
|
|
|
|
|
|
did_perform_work = True
|
|
|
|
did_perform_work = True
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
except StopRequested:
|
|
|
|
|
|
|
|
break
|
|
|
|
finally:
|
|
|
|
finally:
|
|
|
|
if not self.is_horse:
|
|
|
|
if not self.is_horse:
|
|
|
|
self.register_death()
|
|
|
|
self.register_death()
|
|
|
|