backend/core/orchestration_paths.py

"""Stub metryk / logów dla dual orchestration (legacy LangGraph vs GSD)."""
from __future__ import annotations

import logging
from typing import Any

logger = logging.getLogger(__name__)


def record_orchestration_path(path: str, **context: Any) -> None:
    """Rejestruje ścieżkę orkiestracji (counter + structured log)."""
    tags = {"path": path}
    if context:
        tags.update({k: str(v) for k, v in context.items()})
    try:
        from core.telemetry import metrics

        metrics.increment("orchestration_path", tags=tags)
    except Exception:
        pass
    logger.info("[Orchestration] path=%s context=%s", path, context or {})