INNER CODE UNIT · Python

broadcast

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

    async def broadcast(self, message: dict):
        """Send message to all connected clients."""
        for connection in self.active_connections:
            try:
                await connection.send_json(message)
            except Exception as e:
                logger.error(f"Error sending message: {e}")


manager = ConnectionManager()


# --- Pipeline Execution ---

async def run_pipeline(config: PipelineConfig) -> PipelineState:
    """
    Run the error monitoring pipeline with real-time updates.
    """

View source record →