restart actions: delete all dags of workflow before restart

* ref: cern-sis/issues-inspire/issues/526
DonHaul · Aug 9, 2024 · a2d474a · a2d474a
1 parent 91ff61c
commit a2d474a
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/backoffice-repo/backoffice/backoffice/workflows/airflow_utils.py b/backoffice-repo/backoffice/backoffice/workflows/airflow_utils.py
@@ -165,10 +165,6 @@ def restart_workflow_dags(workflow_id, workflow_type, params=None):
     for dag_id in executed_dags_for_workflow:
         delete_workflow_dag(dag_id, str(workflow_id))
 
-        return trigger_airflow_dag(
-            WORKFLOW_DAGS[workflow_type].initialize, str(workflow_id), params
-        )
-
-    return JsonResponse(
-        {"error": "Failed to restart"}, status=status.HTTP_424_FAILED_DEPENDENCY
+    return trigger_airflow_dag(
+        WORKFLOW_DAGS[workflow_type].initialize, str(workflow_id), params
     )