​
prefect.server.services.late_runs

The MarkLateRuns service. Responsible for putting flow runs in a Late state if they are not started on time. The threshold for a late run can be configured by changing PREFECT_API_SERVICES_LATE_RUNS_AFTER_SECONDS.

​
Classes

​
MarkLateRuns

Finds flow runs that are later than their scheduled start time A flow run is defined as “late” if has not scheduled within a certain amount of time after its scheduled start time. The exact amount is configurable in Prefect REST API Settings. Methods:

​
run_once 

run_once(self, db: PrefectDBInterface) -> None
Mark flow runs as late by:
  • Querying for flow runs in a scheduled state that are Scheduled to start in the past
  • For any runs past the “late” threshold, setting the flow run state to a new Late state

​
run_once 

run_once(self) -> None
Represents one loop of the service. Subclasses must override this method. To actually run the service once, call LoopService().start(loops=1) instead of LoopService().run_once(), because this method will not invoke setup and teardown methods properly.

​
service_settings 

service_settings(cls) -> ServicesBaseSetting

​
start 

start(self, loops: None = None) -> NoReturn
Run the service indefinitely.

​
stop 

stop(self, block: bool = True) -> None
Gracefully stops a running LoopService and optionally blocks until the service stops. Args:
  • block: if True, blocks until the service is finished running. Otherwise it requests a stop and returns but the service may still be running a final loop.