horse should always call os._exit(0)

main
Selwin Ong 6 years ago
parent cc19d1a89e
commit 4759c43067

2
.gitignore vendored

@ -15,3 +15,5 @@ Vagrantfile
.idea/ .idea/
.coverage* .coverage*
/.cache /.cache
.pytest_cache/

@ -463,7 +463,6 @@ class Worker(object):
""" """
setup_loghandlers(logging_level, date_format, log_format) setup_loghandlers(logging_level, date_format, log_format)
self._install_signal_handlers() self._install_signal_handlers()
did_perform_work = False did_perform_work = False
self.register_birth() self.register_birth()
self.log.info("RQ worker {0!r} started, version {1}".format(self.key, VERSION)) self.log.info("RQ worker {0!r} started, version {1}".format(self.key, VERSION))
@ -671,16 +670,15 @@ class Worker(object):
# that are different from the worker. # that are different from the worker.
random.seed() random.seed()
self.setup_work_horse_signals() try:
self.setup_work_horse_signals()
self._is_horse = True self._is_horse = True
self.log = logger self.log = logger
self.perform_job(job, queue)
success = self.perform_job(job, queue) finally:
# os._exit() is the way to exit from childs after a fork(), in
# os._exit() is the way to exit from childs after a fork(), in # constrast to the regular sys.exit()
# constrast to the regular sys.exit() os._exit(0)
os._exit(0)
def setup_work_horse_signals(self): def setup_work_horse_signals(self):
"""Setup signal handing for the newly spawned work horse.""" """Setup signal handing for the newly spawned work horse."""

Loading…
Cancel
Save