prefect.server.services.task_run_recorder
causal_ordering
causal_ordering() -> CausalOrdering
task_run_from_event
task_run_from_event(event: ReceivedEvent) -> TaskRun
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(self, value: asyncio.Event) -> None
Was this page helpful?