From 57bd2aec45b74249d20bd92200fc8dc2265055ad Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= Date: Tue, 27 Feb 2018 15:26:16 +0100 Subject: [PATCH] Implement uplink notifications in ProcessManagingEventHandler --- lib/tfw/components/process_managing_event_handler.py | 4 ++++ 1 file changed, 4 insertions(+) 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})