app/agent/nodes/executor.py

"""Executor node: invoke the Skill requested by skill_router and record the result."""
from __future__ import annotations

import logging
from typing import Any

from app.agent.state import AgentState
from app.skills.registry import REGISTRY
from app.utils.trace import generate_trace_id

logger = logging.getLogger(__name__)


async def executor_node(state: AgentState) -> dict[str, Any]:
    """Execute the most recent tool call recorded in state."""
    calls = list(state.get("tool_calls", []))
    if not calls:
        return {"error": "executor called with no tool_calls"}

    pending = calls[-1]
    name = pending["name"]
    args = pending.get("args", {}) or {}
    trace_id = generate_trace_id()
    pending["trace_id"] = trace_id

    logger.info("[%s] dispatching skill %s args=%s", trace_id, name, args)
    result = await REGISTRY.dispatch(name, args)
    pending["result"] = result.to_dict() if result.ok else None
    pending["ok"] = result.ok
    pending["duration_ms"] = result.duration_ms
    pending["error"] = result.error

    return {
        "tool_calls": calls,
        "rounds_used": (state.get("rounds_used", 0) + 1) if not result.ok else state.get("rounds_used", 0),
    }