fix: issues in error handling
This commit is contained in:
@@ -467,6 +467,11 @@ async def websocket_stream(ws: WebSocket) -> None:
|
|||||||
print("Client disconnected (WebSocketDisconnect)")
|
print("Client disconnected (WebSocketDisconnect)")
|
||||||
enqueue_log("client_disconnected")
|
enqueue_log("client_disconnected")
|
||||||
stop_signal.set()
|
stop_signal.set()
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error in websocket stream: {e}")
|
||||||
|
traceback.print_exc()
|
||||||
|
enqueue_log("backend_error", message=str(e))
|
||||||
|
stop_signal.set()
|
||||||
finally:
|
finally:
|
||||||
stop_signal.set()
|
stop_signal.set()
|
||||||
enqueue_log("backend_stream_complete")
|
enqueue_log("backend_stream_complete")
|
||||||
@@ -483,8 +488,11 @@ async def websocket_stream(ws: WebSocket) -> None:
|
|||||||
log_queue.get_nowait()
|
log_queue.get_nowait()
|
||||||
except Empty:
|
except Empty:
|
||||||
break
|
break
|
||||||
|
try:
|
||||||
if ws.client_state == WebSocketState.CONNECTED:
|
if ws.client_state == WebSocketState.CONNECTED:
|
||||||
await ws.close()
|
await ws.close()
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error closing websocket: {e}")
|
||||||
print("WS handler exit")
|
print("WS handler exit")
|
||||||
finally:
|
finally:
|
||||||
if acquired:
|
if acquired:
|
||||||
|
|||||||
Reference in New Issue
Block a user