Handle reusing queue on task events

Author: kthota-g

src/a2a/server/request_handlers/default_request_handler.py

@@ -195,8 +195,10 @@ async def on_message_send_stream(
             consumer = EventConsumer(queue)
             producer_task.add_done_callback(consumer.agent_task_callback)
             async for event in result_aggregator.consume_and_emit(consumer):
-                # Now we know we have a Task, register the queue
-                if isinstance(event, Task):
+                if isinstance(event, Task) and task_id != event.id:
+                    logger.warning(
+                        f'Agent generated task_id={event.id} does not match the RequestContext task_id={task_id}.'
+                    )
                     try:
                         await self._queue_manager.add(event.id, queue)
                         task_id = event.id