​
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

​
enqueue 

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

​
for_key 

for_key(cls, task_key: str) -> Self

​
get 

get(self) -> schemas.core.TaskRun

​
get_nowait 

get_nowait(self) -> schemas.core.TaskRun

​
put 

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

​
reset 

reset(cls) -> None
A unit testing utility to reset the state of the task queues subsystem

​
retry 

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

​
MultiQueue

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

​
get 

get(self) -> schemas.core.TaskRun
Gets the next task_run from any of the given queues