Skip to content

Commit 8903d3b

Browse files
committed
Add error handling in closed shard logic
1 parent 56be8aa commit 8903d3b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

twitchio/client.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3317,7 +3317,10 @@ async def _websocket_closed(self, payload: WebsocketClosed) -> None:
33173317
if payload.socket._shard_id not in self._conduit_info._sockets:
33183318
return
33193319

3320-
await self._associate_shards(shard_ids=[int(payload.socket._shard_id)])
3320+
try:
3321+
await self._associate_shards(shard_ids=[int(payload.socket._shard_id)])
3322+
except Exception as e:
3323+
logger.debug("Error re-associating shards for conduit %r after websocket close: %s", self.conduit_info, e)
33213324

33223325
async def _connect_and_welcome(self, websocket: Websocket) -> bool:
33233326
await websocket.connect(fail_once=False)

0 commit comments

Comments
 (0)