angee.messaging.tasks

Celery task wrappers for outbound messaging delivery.

deliver_message

@shared_task(
    name=DELIVER_MESSAGE_TASK,
    autoretry_for=(TransientDeliveryError, ),
    retry_backoff=True,
    retry_kwargs={"max_retries": 3},
)
def deliver_message(model_label: str, pk: Any,
                    external_id: str) -> dict[str, Any]

Deliver one message; transient exceptions retry the idempotent owner.