diff --git a/lib/tfw/components/pipe_io_event_handler.py b/lib/tfw/components/pipe_io_event_handler.py index 63855b6..d60fedf 100644 --- a/lib/tfw/components/pipe_io_event_handler.py +++ b/lib/tfw/components/pipe_io_event_handler.py @@ -41,7 +41,10 @@ class CallbackPipeIOServer(PipeIOServer): self.callback = callback def handle_message(self, message): - self.callback(message) + try: + self.callback(message) + except: # pylint: disable=bare-except + LOG.exception('Failed to handle message %s from pipe %s!', message, self.in_pipe) class PipeIOEventHandler(PipeIOEventHandlerBase):