prefect.server.services.task_run_recorder

Functions

causal_ordering

causal_ordering() -> CausalOrdering

task_run_from_event

task_run_from_event(event: ReceivedEvent) -> TaskRun

Classes

TaskRunRecorder

Constructs task runs and states from client-emitted events

Methods:

service_settings

service_settings(cls) -> ServicesBaseSetting

started_event

started_event(self) -> asyncio.Event

started_event

started_event(self, value: asyncio.Event) -> None