​
prefect.workers.server

​
Functions

​
build_healthcheck_server 

build_healthcheck_server(worker: BaseWorker[Any, Any, Any], query_interval_seconds: float, log_level: str = 'error') -> uvicorn.Server
Build a healthcheck FastAPI server for a worker. Args:
  • worker: the worker whose health we will check
  • log_level: the log

​
start_healthcheck_server 

start_healthcheck_server(worker: BaseWorker[Any, Any, Any], query_interval_seconds: float, log_level: str = 'error') -> None
Run a healthcheck FastAPI server for a worker. Args:
  • worker: the worker whose health we will check
  • log_level: the log level to use for the server