Google ADK 에이전트 Telemetry

from time import perf_counter

async def run_support_agent(runner, message, run_id, session_id):
    started_at = perf_counter()
    status = "success"
    event_count = 0

    try:
        async for event in runner.run_async(
            user_id="application_user",
            session_id=session_id,
            new_message=message,
        ):
            event_count += 1
            yield event
    except Exception:
        status = "failed"
        raise
    finally:
        await telemetry.log("agent_run_completed", {
            "run_id": run_id,
            "session_id": session_id,
            "workflow": "support_resolution",
            "agent_name": "support_agent",
            "status": status,
            "event_count": event_count,
            "duration_ms": round((perf_counter() - started_at) * 1000),
        })