Function agent_run_span

src/observability/runspan.py:49–78

Start a root span for an agent ``run()`` call. Sets canonical attributes (runner name, GenAI system/model, question length, and any ambient ``agent.run_id`` / ``agent.scenario_id`` from :func:`set_run_context`) and records exceptions on the span before re-raising.

(
    runner_name: str,
    model: str,
    question: str,
)

@contextmanager
def agent_run_span(
    runner_name: str,
    model: str,
    question: str,
) -> Iterator[Any]:
    """Start a root span for an agent ``run()`` call.

    Sets canonical attributes (runner name, GenAI system/model, question
    length, and any ambient ``agent.run_id`` / ``agent.scenario_id`` from
    :func:`set_run_context`) and records exceptions on the span before
    re-raising.
    """
    tracer = get_tracer()
    run_id = _run_id_var.get()
    scenario_id = _scenario_id_var.get()
    with tracer.start_as_current_span(f"agent.run {runner_name}") as span:
        span.set_attribute("agent.runner", runner_name)
        span.set_attribute("gen_ai.system", _system_from_model(model))
        span.set_attribute("gen_ai.request.model", model)
        span.set_attribute("agent.question.length", len(question))
        if run_id:
            span.set_attribute("agent.run_id", run_id)
        if scenario_id:
            span.set_attribute("agent.scenario_id", scenario_id)
        try:
            yield span
        except Exception as exc:
            span.record_exception(exc)
            span.set_status(Status(StatusCode.ERROR, str(exc)))
            raise