Merge pull request #71 from DonHaul/restart-workflow-bug

restart actions: delete all dags of workflow before restart
inspirehep · Aug 9, 2024 · a42554a · a42554a
2 parents a202b4d + 0994f7c
commit a42554a
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/backoffice/backoffice/workflows/airflow_utils.py b/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
     )