Delete a pipeline.
(pipeline_id: str)
| 70 | |
| 71 | @router.delete("/{pipeline_id}") |
| 72 | async def delete_pipeline(pipeline_id: str): |
| 73 | """Delete a pipeline.""" |
| 74 | if pipeline_id not in pipelines_store: |
| 75 | raise HTTPException(status_code=404, detail="Pipeline not found") |
| 76 | |
| 77 | del pipelines_store[pipeline_id] |
| 78 | return {"message": "Pipeline deleted successfully"} |
| 79 | |
| 80 | @router.post("/{pipeline_id}/run") |
| 81 | async def run_pipeline(pipeline_id: str): |
nothing calls this directly
no outgoing calls
no test coverage detected