diff --git a/wsio/finstitutions/trading/tick_out.py b/wsio/finstitutions/trading/tick_out.py index 2b8c0f8..f76c1f1 100644 --- a/wsio/finstitutions/trading/tick_out.py +++ b/wsio/finstitutions/trading/tick_out.py @@ -462,8 +462,8 @@ async def handle_disconnect(sid, reason) -> None: # register the disconnect in the global variable, and on the cache server: client_info = {} - async with exclusive_lock: client_info = CONNECTED_CLIENTS.pop(sid) - sid_uncached = await redis_cache.delete(key = client_info["redisKey"]) + async with exclusive_lock: client_info = CONNECTED_CLIENTS.pop(sid, None) + sid_uncached = await redis_cache.delete(key = client_info["redisKey"]) if client_info else False printer("SOCKET DISCONNECTED", sid, reason, sid_uncached)