prefect.server.task_queue

Implements an in-memory task queue for delivering background task runs to TaskWorkers.

Classes

TaskQueue

Methods:

configure_task_key

configure_task_key(cls, task_key: str, scheduled_size: Optional[int] = None, retry_size: Optional[int] = None) -> None

for_key

for_key(cls, task_key: str) -> Self

reset

reset(cls) -> None

A unit testing utility to reset the state of the task queues subsystem

get_nowait

get_nowait(self) -> schemas.core.TaskRun

MultiQueue

A queue that can pull tasks from from any of a number of task queues