AutoGen 작업 흐름, 상태 및 시간 초과 모니터링

import asyncio
from time import perf_counter

async def run_agent_team(team, task: str, run_id: str):
    started_at = perf_counter()
    status = "success"
    error_type = None
    state_before = "team_started"
    state_after = "team_completed"
    timeout_ms = 120_000
    result = None

    try:
        result = await asyncio.wait_for(
            team.run(task=task),
            timeout=timeout_ms / 1000,
        )
        return result
    except TimeoutError:
        status = "timed_out"
        error_type = "team_timeout"
        state_after = "timeout_reached"
        raise
    except Exception as error:
        status = "failed"
        error_type = classify_agent_error(error)
        state_after = "team_failed"
        raise
    finally:
        await telemetry.log("agent_run_completed", {
            "run_id": run_id,
            "workflow": "support_resolution",
            "team_name": "support_team",
            "status": status,
            "error_type": error_type,
            "state_before": state_before,
            "state_after": state_after,
            "timeout_ms": timeout_ms,
            "timed_out": status == "timed_out",
            "termination_reason": getattr(result, "stop_reason", None),
            "message_count": len(result.messages) if result else 0,
            "duration_ms": round((perf_counter() - started_at) * 1000),
            "release": APP_RELEASE,
        })