diff --git a/lib/tfw/components/process_managing_event_handler.py b/lib/tfw/components/process_managing_event_handler.py index eae199a..e8e0ccd 100644 --- a/lib/tfw/components/process_managing_event_handler.py +++ b/lib/tfw/components/process_managing_event_handler.py @@ -1,5 +1,6 @@ from tfw.event_handler_base import TriggerlessEventHandler from tfw.components.mixins import SupervisorMixin +from tfw.networking.event_handlers.server_connector import ServerUplinkConnector from tfw.config.logs import logging log = logging.getLogger(__name__) @@ -18,7 +19,10 @@ class ProcessManager(SupervisorMixin): class ProcessManagingEventHandler(TriggerlessEventHandler): def __init__(self, key, supervisor_process_name): super().__init__(key) + self.key = key self.processmanager = ProcessManager(supervisor_process_name) + self.uplink = ServerUplinkConnector() def handle_event(self, key, data_json): self.processmanager(data_json['data']['command']) + self.uplink.send(self.key, {'key': self.key})