@@ -453,14 +453,14 @@ async def get_computation(
453453 # check that project actually exists
454454 await project_repo .get_project (project_id )
455455
456- pipeline_dag , all_tasks , _filtered_tasks = await validate_pipeline (
456+ pipeline_info = await validate_pipeline (
457457 project_id , comp_pipelines_repo , comp_tasks_repo
458458 )
459459
460460 # create the complete DAG graph
461- complete_dag = create_complete_dag_from_tasks (all_tasks )
461+ complete_dag = create_complete_dag_from_tasks (pipeline_info . all_tasks )
462462 pipeline_details = await compute_pipeline_details (
463- complete_dag , pipeline_dag , all_tasks
463+ complete_dag , pipeline_info . pipeline_dag , pipeline_info . filtered_tasks
464464 )
465465
466466 # get run details if any
@@ -492,8 +492,12 @@ async def get_computation(
492492 ),
493493 iteration = last_run .iteration if last_run else None ,
494494 result = None ,
495- started = compute_pipeline_started_timestamp (pipeline_dag , all_tasks ),
496- stopped = compute_pipeline_stopped_timestamp (pipeline_dag , all_tasks ),
495+ started = compute_pipeline_started_timestamp (
496+ pipeline_info .pipeline_dag , pipeline_info .all_tasks
497+ ),
498+ stopped = compute_pipeline_stopped_timestamp (
499+ pipeline_info .pipeline_dag , pipeline_info .all_tasks
500+ ),
497501 submitted = last_run .created if last_run else None ,
498502 )
499503
0 commit comments