Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.prefect.io/llms.txt

Use this file to discover all available pages before exploring further.

​
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.