(self)
| 8 | """Manages WebSocket connections for real-time communication.""" |
| 9 | |
| 10 | def __init__(self): |
| 11 | # Store active connections by pipeline_id |
| 12 | self.active_connections: Dict[str, List[WebSocket]] = {} |
| 13 | # Store pipeline states |
| 14 | self.pipeline_states: Dict[str, Dict] = {} |
| 15 | |
| 16 | async def connect(self, websocket: WebSocket, pipeline_id: str): |
| 17 | """Accept and store a new WebSocket connection.""" |
nothing calls this directly
no outgoing calls
no test coverage detected