Get current workflow state.
(pipeline_id: str, manager: WorkflowManager = Depends(get_manager))
| 44 | |
| 45 | @router.get("/workflow/{pipeline_id}") |
| 46 | async def get_workflow(pipeline_id: str, manager: WorkflowManager = Depends(get_manager)): |
| 47 | """Get current workflow state.""" |
| 48 | workflow = manager.get_workflow(pipeline_id) |
| 49 | if not workflow: |
| 50 | raise HTTPException(status_code=404, detail="Workflow not found") |
| 51 | |
| 52 | return workflow.dict() |
| 53 | |
| 54 | |
| 55 | @router.get("/workflow/{pipeline_id}/summary") |
nothing calls this directly
no test coverage detected