task_run_recorder

prefect.server.services.task_run_recorder

Functions

causal_ordering

causal_ordering() -> CausalOrdering

task_run_from_event

task_run_from_event(event: ReceivedEvent) -> TaskRun

record_task_run_event

record_task_run_event(event: ReceivedEvent) -> None

consumer

consumer() -> AsyncGenerator[MessageHandler, None]

Classes

TaskRunRecorder

Constructs task runs and states from client-emitted events

Methods:

all_services

all_services(cls) -> Sequence[type[Self]]

Get list of all service classes

enabled

enabled(cls) -> bool

Whether the service is enabled

enabled_services

enabled_services(cls) -> list[type[Self]]

Get list of enabled service classes

environment_variable_name

environment_variable_name(cls) -> str

run_services

run_services(cls) -> NoReturn

Run enabled services until cancelled.

running

running(cls) -> AsyncGenerator[None, None]

A context manager that runs enabled services on entry and stops them on exit.

service_settings

service_settings(cls) -> ServicesBaseSetting

service_settings

service_settings(cls) -> ServicesBaseSetting

The Prefect setting that controls whether the service is enabled

start

start(self) -> NoReturn

start

start(self) -> NoReturn

Start running the service, which may run indefinitely

started_event

started_event(self) -> asyncio.Event

started_event

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

stop

stop(self) -> None

stop

stop(self) -> None

Stop the service