INNER CODE UNIT · Python

PipelineStep

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

class PipelineStep(BaseModel):
    """Represents a single step in the pipeline."""
    id: str
    name: str
    status: str  # "pending", "running", "completed", "error"
    data: Optional[Dict[str, Any]] = None
    reasoning: Optional[str] = None
    duration_ms: Optional[int] = None


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

View source record →