From d11d9a70cb466583b39140c92a67f15d321297c7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= Date: Wed, 7 Mar 2018 14:47:24 +0100 Subject: [PATCH] Remove TFW antipattern I wrote without thinking --- lib/tfw/components/process_managing_event_handler.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/lib/tfw/components/process_managing_event_handler.py b/lib/tfw/components/process_managing_event_handler.py index ab63607..ea28103 100644 --- a/lib/tfw/components/process_managing_event_handler.py +++ b/lib/tfw/components/process_managing_event_handler.py @@ -2,7 +2,6 @@ from functools import wraps 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__) @@ -23,7 +22,6 @@ class ProcessManagingEventHandler(TriggerlessEventHandler): self.key = key self.monitor = dirmonitor self.processmanager = ProcessManager() - self.uplink = ServerUplinkConnector() def _with_monitor_paused(fun): @wraps(fun) @@ -39,6 +37,6 @@ class ProcessManagingEventHandler(TriggerlessEventHandler): try: data = data_json['data'] self.processmanager(data['command'], data['process_name']) - self.uplink.send(self.key, {'data': {'process_name': data['process_name']}}) + return data_json except KeyError: log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))