fix

guglielmo-san · guglielmo-san · commit 1ce4368aae99 · 2026-04-03T10:41:20.000Z
diff --git a/src/a2a/server/routes/jsonrpc_dispatcher.py b/src/a2a/server/routes/jsonrpc_dispatcher.py
@@ -452,11 +452,11 @@ async def _process_streaming_request(
         stream: AsyncGenerator | None = None
         if context.state.get('method') == 'SendStreamingMessage':
             stream = self.request_handler.on_message_send_stream(
-                cast(SendMessageRequest, request_obj), context
+                cast('SendMessageRequest', request_obj), context
             )
         elif context.state.get('method') == 'SubscribeToTask':
             stream = self.request_handler.on_subscribe_to_task(
-                cast(SubscribeToTaskRequest, request_obj), context
+                cast('SubscribeToTaskRequest', request_obj), context
             )
 
         if stream is None:

Original file line number	Diff line number	Diff line change
`@@ -452,11 +452,11 @@ async def _process_streaming_request(`
`452`	`452`	`stream: AsyncGenerator \| None = None`
`453`	`453`	`if context.state.get('method') == 'SendStreamingMessage':`
`454`	`454`	`stream = self.request_handler.on_message_send_stream(`
`455`		`- cast(SendMessageRequest, request_obj), context`
	`455`	`+ cast('SendMessageRequest', request_obj), context`
`456`	`456`	`)`
`457`	`457`	`elif context.state.get('method') == 'SubscribeToTask':`
`458`	`458`	`stream = self.request_handler.on_subscribe_to_task(`
`459`		`- cast(SubscribeToTaskRequest, request_obj), context`
	`459`	`+ cast('SubscribeToTaskRequest', request_obj), context`
`460`	`460`	`)`
`461`	`461`
`462`	`462`	`if stream is None:`