`prefect.telemetry.run_telemetry`

Classes

A setter for OpenTelemetry that supports Prefect’s custom labels. Methods:

set(self, carrier: KeyValueLabels, key: str, value: str) -> None

A class for managing the telemetry of runs. Methods:

async_start_span(self, run: FlowOrTaskRun, client: PrefectClient, parameters: dict[str, Any] | None = None) -> Span | None

end_span_on_failure(self, terminal_message: str | None = None) -> None

End a span for a run on failure.

end_span_on_success(self) -> None

End a span for a run on success.

record_exception(self, exc: BaseException) -> None

Record an exception on a span.

start_span(self, run: FlowOrTaskRun, client: SyncPrefectClient, parameters: dict[str, Any] | None = None) -> Span | None

traceparent_from_span(span: Span) -> str | None

update_run_name(self, name: str) -> None

Update the name of the run.

update_state(self, new_state: State) -> None

Update a span with the state of a run.