Add endpoint to API Server deployments resource to get event stream using client's get_task_result_stream method. #111

New Issue

2026-02-16T01:15:49-05:00

yindo commented

2026-02-16 01:15:49 -05:00

Originally created by @nerdai on GitHub (Oct 7, 2024).

Originally assigned to: @nerdai on GitHub.

(The control plane already consumes the stream messages from the Workflow services and emits SSE using FastAPI StreamingResponse)

Implement the equivalent of what we have in workflows:

handler = workflow.run()
async for event in handler.stream_events():
    # do something with event
    pass

for Llama Deploy through the API Server, something like GET http://apiserver.local/my-deployment/events

Acceptance Criteria

there is an endpoint in the API Server that allows user to get events streamed from a task

Originally created by @nerdai on GitHub (Oct 7, 2024). Originally assigned to: @nerdai on GitHub. (The control plane already consumes the stream messages from the Workflow services and emits SSE using FastAPI StreamingResponse) Implement the equivalent of what we have in workflows: ```python handler = workflow.run() async for event in handler.stream_events(): # do something with event pass ``` for Llama Deploy through the API Server, something like GET http://apiserver.local/my-deployment/events **Acceptance Criteria** - there is an endpoint in the API Server that allows user to get events streamed from a task

yindo closed this issue

2026-02-16 01:15:49 -05:00

yindo referenced this issue

2026-02-16 01:16:41 -05:00

[PR #111] [MERGED] Some unit tests for RabbitMQMessageQueue #270

Sign in to join this conversation.