INNER CODE UNIT · Python
run_demo
airweave-ai/error-monitoring-agent · backend/main.py:544
async def run_demo(config: PipelineConfig):
"""
Start a pipeline run.
The actual execution happens via WebSocket for real-time updates.
"""
# Run pipeline in background task
asyncio.create_task(run_pipeline(config))
return {"status": "started", "message": "Pipeline started. Connect to WebSocket for updates."}
@app.websocket("/ws/pipeline")
async def websocket_endpoint(websocket: WebSocket):
"""
WebSocket endpoint for real-time pipeline updates.
Messages sent:
- pipeline_started: Pipeline execution has begun
- step_started: A step has started processing