`prefect.server.task_queue`

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

Classes

Methods:

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

enqueue(cls, task_run: schemas.core.TaskRun) -> None

for_key(cls, task_key: str) -> Self

get(self) -> schemas.core.TaskRun

get_nowait(self) -> schemas.core.TaskRun

put(self, task_run: schemas.core.TaskRun) -> None

reset(cls) -> None

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

retry(self, task_run: schemas.core.TaskRun) -> None

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

get(self) -> schemas.core.TaskRun

Gets the next task_run from any of the given queues