@@ -483,7 +483,7 @@ async def sse_writer():
483483 ):
484484 break
485485 except Exception as e :
486- logger .exception (f"Error in SSE writer: { e } " )
486+ logger .warning (f"Error in SSE writer: { e } " , exc_info = True )
487487 finally :
488488 logger .debug ("Closing SSE writer" )
489489 await self ._clean_up_memory_streams (request_id )
@@ -517,13 +517,13 @@ async def sse_writer():
517517 session_message = SessionMessage (message , metadata = metadata )
518518 await writer .send (session_message )
519519 except Exception :
520- logger .exception ("SSE response error" )
520+ logger .warning ("SSE response error" , exc_info = True )
521521 await sse_stream_writer .aclose ()
522522 await sse_stream_reader .aclose ()
523523 await self ._clean_up_memory_streams (request_id )
524524
525525 except Exception as err :
526- logger .exception ("Error handling POST request" )
526+ logger .warning ("Error handling POST request" , exc_info = True )
527527 response = self ._create_error_response (
528528 f"Error handling POST request: { err } " ,
529529 HTTPStatus .INTERNAL_SERVER_ERROR ,
@@ -610,7 +610,7 @@ async def standalone_sse_writer():
610610 event_data = self ._create_event_data (event_message )
611611 await sse_stream_writer .send (event_data )
612612 except Exception as e :
613- logger .exception (f"Error in standalone SSE writer: { e } " )
613+ logger .warning (f"Error in standalone SSE writer: { e } " , exc_info = True )
614614 finally :
615615 logger .debug ("Closing standalone SSE writer" )
616616 await self ._clean_up_memory_streams (GET_STREAM_KEY )
@@ -626,7 +626,7 @@ async def standalone_sse_writer():
626626 # This will send headers immediately and establish the SSE connection
627627 await response (request .scope , request .receive , send )
628628 except Exception as e :
629- logger .exception (f"Error in standalone SSE response: { e } " )
629+ logger .warning (f"Error in standalone SSE response: { e } " , exc_info = True )
630630 await sse_stream_writer .aclose ()
631631 await sse_stream_reader .aclose ()
632632 await self ._clean_up_memory_streams (GET_STREAM_KEY )
0 commit comments