From 53c30062abdba957850a0d6658cabd369ad3cbac Mon Sep 17 00:00:00 2001 From: jcass77 Date: Wed, 5 Aug 2020 09:42:18 +0200 Subject: [PATCH] wip: Resolve process hangs during shutdown. --- wtfix/apps/sessions.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/wtfix/apps/sessions.py b/wtfix/apps/sessions.py index 4d0df3a..ac5376b 100644 --- a/wtfix/apps/sessions.py +++ b/wtfix/apps/sessions.py @@ -234,7 +234,9 @@ async def listen(self): f"'{utils.decode(e.partial)}' ({e})." ) + # Stop listening for messages asyncio.create_task(self.pipeline.stop()) + break except LimitOverrunError as e: # Buffer limit reached before a complete message could be read - abort! @@ -242,7 +244,9 @@ async def listen(self): f"{self.name}: Stream reader buffer limit exceeded! ({e})." ) + # Stop listening for messages asyncio.create_task(self.pipeline.stop()) + break async def on_send(self, message): """