Merge pull request #4477 from ryanpetrello/372-signal-deadlock

force worker processes to have a different signal handler from the parent
This commit is contained in:
Ryan Petrello
2020-07-23 12:21:44 -04:00
committed by GitHub
2 changed files with 2 additions and 0 deletions

View File

@@ -35,6 +35,7 @@ class WorkerSignalHandler:
def __init__(self): def __init__(self):
self.kill_now = False self.kill_now = False
signal.signal(signal.SIGTERM, signal.SIG_DFL)
signal.signal(signal.SIGINT, self.exit_gracefully) signal.signal(signal.SIGINT, self.exit_gracefully)
def exit_gracefully(self, *args, **kwargs): def exit_gracefully(self, *args, **kwargs):

View File

@@ -581,3 +581,4 @@ class TaskManager():
logger.debug("Starting Scheduler") logger.debug("Starting Scheduler")
with task_manager_bulk_reschedule(): with task_manager_bulk_reschedule():
self._schedule() self._schedule()
logger.debug("Finishing Scheduler")