From 02410b270d025e5fb8cb4e2036fb627051c7850a Mon Sep 17 00:00:00 2001 From: mvdbeek Date: Mon, 8 Oct 2018 18:53:07 +0200 Subject: [PATCH] Register job monitor as postfork function This should fix https://github.com/galaxyproject/galaxy/issues/6831, and might fix https://github.com/galaxyproject/galaxy/issues/6261. --- lib/galaxy/util/monitors.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lib/galaxy/util/monitors.py b/lib/galaxy/util/monitors.py index 63c2e1a43e9..fc03daedb12 100644 --- a/lib/galaxy/util/monitors.py +++ b/lib/galaxy/util/monitors.py @@ -3,6 +3,7 @@ from __future__ import absolute_import import logging import threading +from galaxy.web.stack import register_postfork_function from .sleeper import Sleeper log = logging.getLogger(__name__) @@ -27,7 +28,11 @@ class Monitors: self.sleeper = Sleeper() self.monitor_thread = threading.Thread(name=name, target=monitor_func) self.monitor_thread.setDaemon(True) - if start: + self._start = start + register_postfork_function(self.start_monitoring) + + def start_monitoring(self): + if self._start: self.monitor_thread.start() def stop_monitoring(self):