Consuming streaming events twice hangs indefinitely #14

Closed
opened 2026-02-16 02:16:05 -05:00 by yindo · 0 comments
Owner

Originally created by @masci on GitHub (Aug 6, 2025).

Example pseudo-code:

workflow = MyWorkflow()
handle = workflow.run()

# This works as expected, loop is exited when StopEvent is sent
async for event in handle.stream_events():
    print("got event from first handle iteration", event)

# This will hang forever
async for event in handle.stream_events():
    print("got event from second handle iteration", event)
Originally created by @masci on GitHub (Aug 6, 2025). Example pseudo-code: ```py workflow = MyWorkflow() handle = workflow.run() # This works as expected, loop is exited when StopEvent is sent async for event in handle.stream_events(): print("got event from first handle iteration", event) # This will hang forever async for event in handle.stream_events(): print("got event from second handle iteration", event) ```
yindo closed this issue 2026-02-16 02:16:05 -05:00
Sign in to join this conversation.
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: run-llama/workflows-py#14