from typing import Dict, Any
from backend.services.executor import QueryExecutor

class OrchestratorAgent:
    def __init__(self):
        self.executor = QueryExecutor()

    async def process_query(self, query: str, history: list[Dict[str, str]] = None, model: str = None) -> Dict[str, Any]:
        """
        Delegates to QueryExecutor. Model param can be used to configure LLM if needed.
        """
        # For now, we rely on the default configured in LLMGateway
        return await self.executor.process_query_with_context(query, history or [])