prefect.server.orchestration.instrumentation_policies

Orchestration rules related to instrumenting the orchestration engine for Prefect Observability

Classes

InstrumentFlowRunStateTransitions

When a Flow Run changes states, fire a Prefect Event for the state change Methods:

after_transition

after_transition(self, context: OrchestrationContext[orm_models.FlowRun, core.FlowRunPolicy]) -> None