a2aproject / a2aproject/a2a-samples

[Question] Langgraph A2A sample: Streaming output is not sent per node as expected, but is output together

Abierto
#141 1 comentario 1 reacción 0 asignados Ver en GitHub
Lenguaje dominante
Jupyter Notebook
Estrellas
1.8k
Forks
751
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

I am following the Python Quickstart Tutorial of streaming and it is generally working fine:
https://google-a2a.github.io/A2A/tutorials/python/7-streaming-and-multiturn/

**However, the timing of the streaming output does not behave as expected.**
Currently, it seems that the streaming output only starts after all nodes have completed, rather than emitting intermediate results as each node finishes.

To confirm this, I added a time.sleep() delay inside the tool nodes. As a result, the streaming output was delayed by that same duration, which suggests that the system waits until all processing is complete before emitting chunks.

That said, based on the code here, I believe the intended behavior is to emit streaming chunks after each node finishes, not just at the end:
https://github.com/google-a2a/a2a-samples/blob/4ae4600f219d51b37e6df9bbb7e9608df0058c08/samples/python/agents/langgraph/app/agent_executor.py#L50-L62

**Is this a known limitation or am I missing some setting?**
If there is a way to output per node, please let me know.

Branch used: main
(commit: 4ae4600f219d51b37e6df9bbb7e9608df0058c08)

Guía de contribución

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.