INNER CODE UNIT · Python

PipelineState

airweave-ai/error-monitoring-agent · backend/main.py:59

class PipelineState(BaseModel):
    """Current state of the pipeline."""
    run_id: str
    status: str  # "idle", "running", "completed", "error"
    current_step: int
    steps: List[PipelineStep]
    started_at: Optional[str] = None
    completed_at: Optional[str] = None


# --- WebSocket Connection Manager ---

class ConnectionManager:
    """Manages WebSocket connections for real-time updates."""
    
    def __init__(self):
        self.active_connections: List[WebSocket] = []
    

View source record →