INNER CODE UNIT · Python

_start_task_queue_observability_poller

skygazer42/MimirQ · app/main.py:306

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])


def _bm25_startup_skip_message() -> str | None:
    if not bool(getattr(settings, "BM25_INDEX_ENABLED", True)):
        return "BM25 indexing disabled; skipping startup build"
    if not bool(getattr(settings, "BM25_STARTUP_BUILD_ENABLED", False)):
        return "BM25 startup build disabled (BM25_STARTUP_BUILD_ENABLED=false)"
    return None

View source record →