task_delivery

prefect.server.task_delivery

Durable delivery of deferred task runs to TaskWorkers.

Functions

schedule_task_run_delivery

schedule_task_run_delivery(task_run: schemas.core.TaskRun) -> None

Schedule a deferred task run for delivery through Docket.

deliver_task_run

deliver_task_run(task_run: schemas.core.TaskRun, visibility_timeout_seconds: float, kind: str, max_size: int, perpetual: Perpetual = Perpetual(), docket: Docket = CurrentDocket()) -> None

Offer a task run until a TaskWorker acknowledges it.

task_run_delivery_lifespan

task_run_delivery_lifespan(docket: Docket) -> AsyncGenerator[TaskRunDeliveryManager, None]

Configure deferred task delivery for an API process.

Classes

TaskDeliveryUnavailable

Raised when task delivery has not been configured.

TaskRunDelivery

TaskRunSubscription

A TaskWorker subscription to one or more task-key queues.

Methods:

acknowledge

acknowledge(self, delivery: TaskRunDelivery) -> None

Acknowledge a task run accepted by the connected TaskWorker.

receive

receive(self, timeout: float = 1) -> TaskRunDelivery

Receive a task run matching this subscription.

TaskRunDeliveryManager

Schedules Docket executions and creates keyed TaskWorker subscriptions.

Methods:

active

active(cls) -> 'TaskRunDeliveryManager'

publish

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

reconcile

reconcile(self, task_run: schemas.core.TaskRun) -> bool

Restore delivery for a deferred task run if its execution is absent.

schedule

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

subscribe

subscribe(self, task_keys: list[str]) -> TaskRunSubscription