INNER CODE UNIT · Python

run_pipeline

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

async def run_pipeline(config: PipelineConfig) -> PipelineState:
    """
    Run the error monitoring pipeline with real-time updates.
    """
    run_id = f"run-{datetime.utcnow().strftime('%Y%m%d-%H%M%S')}"
    
    # Initialize pipeline state
    steps = [
        PipelineStep(id="raw-errors", name="Raw Errors", status="pending"),
        PipelineStep(id="clustering", name="Semantic Clustering", status="pending"),
        PipelineStep(id="context-search", name="Context Search", status="pending"),
        PipelineStep(id="analysis", name="Severity Analysis", status="pending"),
        PipelineStep(id="alert-preview", name="Alert Preview", status="pending"),
    ]
    
    state = PipelineState(
        run_id=run_id,
        status="running",

View source record →