Documentation Index
Fetch the complete documentation index at: https://docs.prefect.io/llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.task_queue
Implements an in-memory task queue for delivering background task runs to TaskWorkers.
Classes
TaskQueue
Methods:
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
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
