prefect.server.task_queue

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

Classes

TaskQueue ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L17" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Methods:

configure_task_key ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L36" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

enqueue ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L32" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

for_key ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L47" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

for_key(cls, task_key: str) -> Self

get ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L66" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get(self) -> schemas.core.TaskRun

get_nowait ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L73" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get_nowait(self) -> schemas.core.TaskRun

put ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L80" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

reset ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L56" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

reset(cls) -> None

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

retry ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L83" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

MultiQueue ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L87" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

Methods:

get ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/task_queue.py#L95" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get(self) -> schemas.core.TaskRun

Gets the next task_run from any of the given queues