diff --git a/pipeline.py b/pipeline.py index 8eadbfaf..73413848 100644 --- a/pipeline.py +++ b/pipeline.py @@ -377,13 +377,13 @@ def pipeline( ) output_pvc_delete_task = DeletePVC(pvc_name=output_pvc_task.output) - output_pvc_delete_task.after(output_data_task) + output_pvc_delete_task.after(final_eval_task, output_data_task) sdg_pvc_delete_task = DeletePVC(pvc_name=sdg_input_pvc_task.output) - sdg_pvc_delete_task.after(output_data_task) + sdg_pvc_delete_task.after(final_eval_task, output_data_task) model_pvc_delete_task = DeletePVC(pvc_name=model_pvc_task.output) - model_pvc_delete_task.after(output_data_task) + model_pvc_delete_task.after(final_eval_task, output_data_task) return diff --git a/pipeline.yaml b/pipeline.yaml index 5b5c3e5d..1155e313 100644 --- a/pipeline.yaml +++ b/pipeline.yaml @@ -1549,6 +1549,7 @@ root: dependentTasks: - createpvc-3 - pvc-to-model-op + - run-final-eval-op inputs: parameters: pvc_name: @@ -1565,6 +1566,7 @@ root: dependentTasks: - createpvc-2 - pvc-to-model-op + - run-final-eval-op inputs: parameters: pvc_name: @@ -1581,6 +1583,7 @@ root: dependentTasks: - createpvc - pvc-to-model-op + - run-final-eval-op inputs: parameters: pvc_name: