Function run_sdk_cli

src/agent/_cli_common.py:130–155

Run the standard SDK-CLI lifecycle. Loads ``.env``, parses args with the caller's parser factory, configures stderr logging, initialises OTEL tracing under *service_name*, auto-fills ``args.run_id`` with a UUID4 when the user omitted ``--run-id``, seeds the ambient run context so th

(
    service_name: str,
    build_parser: Callable[[], argparse.ArgumentParser],
    run_coro: Callable[[argparse.Namespace], Awaitable[None]],
)

def run_sdk_cli(
    service_name: str,
    build_parser: Callable[[], argparse.ArgumentParser],
    run_coro: Callable[[argparse.Namespace], Awaitable[None]],
) -> None:
    """Run the standard SDK-CLI lifecycle.

    Loads ``.env``, parses args with the caller's parser factory, configures
    stderr logging, initialises OTEL tracing under *service_name*, auto-fills
    ``args.run_id`` with a UUID4 when the user omitted ``--run-id``, seeds
    the ambient run context so the root span gets
    ``agent.run_id`` / ``agent.scenario_id`` attributes, and runs *run_coro*
    to completion via :func:`asyncio.run`.
    """
    from dotenv import load_dotenv

    from observability import init_tracing, set_run_context

    load_dotenv()
    args = build_parser().parse_args()
    setup_logging(args.verbose)
    init_tracing(service_name)
    if getattr(args, "run_id", None) is None:
        args.run_id = str(uuid.uuid4())
    set_run_context(run_id=args.run_id, scenario_id=getattr(args, "scenario_id", None))
    asyncio.run(run_coro(args))