| 11 | CANCELLED = "cancelled" |
| 12 | |
| 13 | class Pipeline(BaseModel): |
| 14 | id: str |
| 15 | name: str |
| 16 | description: Optional[str] = None |
| 17 | urls: List[str] = [] |
| 18 | schema: Dict[str, Any] = {} |
| 19 | code: str = "" |
| 20 | status: PipelineStatus = PipelineStatus.IDLE |
| 21 | created_at: datetime |
| 22 | updated_at: datetime |
| 23 | user_id: Optional[str] = None |
| 24 | results_count: int = 0 |
| 25 | last_run: Optional[datetime] = None |
| 26 | |
| 27 | class PipelineCreate(BaseModel): |
| 28 | name: str |