"""Catalog Engine — Celery tasks."""

from __future__ import annotations

from celery import shared_task


@shared_task(
    name="catalog.ai_generate_description",
    max_retries=2,
    default_retry_delay=60,
    acks_late=True,
)
def ai_generate_description(item_id: str, tenant_id: int) -> None:
    import structlog
    _log = structlog.get_logger("simorgh.catalog.tasks")
    _log.info("catalog.ai_description_requested", item_id=item_id, tenant_id=tenant_id)