diff --git a/lib/tfw/components/log_monitor.py b/lib/tfw/components/log_monitor.py index e3b5e2b..bebc172 100644 --- a/lib/tfw/components/log_monitor.py +++ b/lib/tfw/components/log_monitor.py @@ -29,6 +29,7 @@ class LogMonitor(ObserverMixin): class SendLogWatchdogEventHandler(PatternMatchingWatchdogEventHandler, SupervisorLogMixin): def __init__(self, process_name): + self.threadlocalise_supervisor_instance() self.process_name = process_name self.procinfo = self.supervisor.getProcessInfo(self.process_name) super().__init__([self.procinfo['stdout_logfile'], self.procinfo['stderr_logfile']]) @@ -41,9 +42,9 @@ class SendLogWatchdogEventHandler(PatternMatchingWatchdogEventHandler, Superviso @RateLimiter(rate_per_second=5) def on_modified(self, event): self.uplink.send({ - 'key': 'console', + 'key': 'processlog', 'data': { - 'command': 'writelog', + 'command': 'new_log', 'stdout': self.read_stdout(self.process_name), 'stderr': self.read_stderr(self.process_name) }