angee.jobs.enqueue

Small task submission API over Celery.

enqueue_task

def enqueue_task(name: str,
                 *,
                 kwargs: Mapping[str, Any],
                 eta: datetime | None = None,
                 queue: str | None = None,
                 expires: float | datetime | None = None) -> None

Send one named Celery task.

expires (seconds or an absolute instant) discards the task if no worker picks it up in time — a periodic reconciler enqueues with the tick period so a saturated or absent worker never accumulates a stale backlog.