Closed nerdai closed 1 month ago
(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
(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:
for Llama Deploy through the API Server, something like GET http://apiserver.local/my-deployment/events
Acceptance Criteria