fix: re-raise CancelledError in UserDataStream for proper task cancellation
Made-with: Cursor
This commit is contained in:
@@ -59,10 +59,13 @@ class UserDataStream:
|
|||||||
except asyncio.CancelledError:
|
except asyncio.CancelledError:
|
||||||
logger.info("User Data Stream 정상 종료")
|
logger.info("User Data Stream 정상 종료")
|
||||||
if self._listen_key:
|
if self._listen_key:
|
||||||
await self._exchange.delete_listen_key(self._listen_key)
|
try:
|
||||||
|
await self._exchange.delete_listen_key(self._listen_key)
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
if self._keepalive_task:
|
if self._keepalive_task:
|
||||||
self._keepalive_task.cancel()
|
self._keepalive_task.cancel()
|
||||||
break
|
raise
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.warning(
|
logger.warning(
|
||||||
|
|||||||
Reference in New Issue
Block a user