Get the current status of a pipeline.
(pipeline_id: str)
| 102 | |
| 103 | @router.get("/{pipeline_id}/status") |
| 104 | async def get_pipeline_status(pipeline_id: str): |
| 105 | """Get the current status of a pipeline.""" |
| 106 | if pipeline_id not in pipelines_store: |
| 107 | raise HTTPException(status_code=404, detail="Pipeline not found") |
| 108 | |
| 109 | pipeline = pipelines_store[pipeline_id] |
| 110 | |
| 111 | return { |
| 112 | "pipeline_id": pipeline_id, |
| 113 | "status": pipeline.status, |
| 114 | "updated_at": pipeline.updated_at |
| 115 | } |
| 116 | |
| 117 | @router.get("/{pipeline_id}/results") |
| 118 | async def get_pipeline_results(pipeline_id: str): |
nothing calls this directly
no outgoing calls
no test coverage detected