INNER CODE UNIT · Python

_initialize_task_queue

skygazer42/MimirQ · app/main.py:299

async def _initialize_task_queue() -> None:
    try:
        await init_queue()
    except Exception as exc:  # noqa: BLE001
        logger.warning("Failed to init task queue: %s", str(exc)[:200])


def _start_task_queue_observability_poller() -> None:
    if not bool(getattr(settings, "PROMETHEUS_ENABLED", False)):
        return
    try:
        from app.services.task_queue_observability_service import start_task_queue_observability_poller

        start_task_queue_observability_poller()
    except Exception as exc:  # noqa: BLE001
        logger.warning("Failed to start task queue observability poller: %s", str(exc)[:200])

View source record →