INNER CODE UNIT · Python

ws_projects

Xeron2000/openOii · backend/app/main.py:119

    async def ws_projects(websocket: WebSocket, project_id: int):
        from app.agents.orchestrator import (
            get_awaiting_payload,
            trigger_confirm_redis,
        )

        try:
            await ws_manager.connect(project_id, websocket)
            await ws_manager.send_event(
                project_id, {"type": "connected", "data": {"project_id": project_id}}
            )

            # 补发当前项目下任意 running run 的状态，防止客户端错过事件
            try:
                from app.db.session import async_session_maker
                from app.models.agent_run import AgentRun
                from sqlalchemy import select

View source record →