prefect.server.orchestration.instrumentation_policies

Orchestration rules related to instrumenting the orchestration engine for Prefect Observability

Classes

InstrumentFlowRunStateTransitions ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/orchestration/instrumentation_policies.py#L25" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

Methods:

after_transition ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/orchestration/instrumentation_policies.py#L28" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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