Skip to main content

prefect.events.subscribers

Flow run subscriber that interleaves events and logs from a flow run

Classes

FlowRunSubscriber

Subscribes to both events and logs for a specific flow run, yielding them in an interleaved stream. This subscriber combines the event stream and log stream for a flow run into a single async iterator. When a terminal event (Completed, Failed, or Crashed) is received, the event subscription stops but log subscription continues for a configurable timeout to catch any straggler logs.
I