Stop raising asyncio.CancelledError if the connection is already clos…

…ed (slackapi#1152) * Update async_client.py * Update slack_sdk/socket_mode/async_client.py Co-authored-by: Kazuhiro Sera <[email protected]>
seratch · Jan 21, 2022 · afa40ea · afa40ea
1 parent 2dee665
commit afa40ea
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/slack_sdk/socket_mode/async_client.py b/slack_sdk/socket_mode/async_client.py
@@ -122,6 +122,11 @@ async def process_messages(self):
             while not self.closed:
                 try:
                     await self.process_message()
+                except asyncio.CancelledError:
+                    # if self.closed is True, the connection is already closed
+                    # In this case, we can ignore the exception here
+                    if not self.closed:
+                        raise
                 except Exception as e:
                     self.logger.exception(
                         f"Failed to process a message: {e}, session: {session_id}"