File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change 3939 rest_error_handler ,
4040 rest_stream_error_handler ,
4141)
42- from a2a .utils .errors import ServerError
42+ from a2a .utils .errors import InvalidRequestError , ServerError
4343
4444
4545logger = logging .getLogger (__name__ )
@@ -126,7 +126,13 @@ async def _handle_streaming_request(
126126 try :
127127 await request .body ()
128128 except (ValueError , RuntimeError , OSError ) as e :
129- logger .warning (f'Failed to pre-consume request body: { e } ' )
129+ logger .warning ('Failed to pre-consume request body: %s' , e )
130+ raise ServerError (
131+ error = InvalidRequestError (
132+ message = f'Failed to pre-consume request body: { e } '
133+ )
134+ )
135+
130136 call_context = self ._context_builder .build (request )
131137
132138 async def event_generator (
You can’t perform that action at this time.
0 commit comments