Skip to content
This repository has been archived by the owner on Nov 21, 2024. It is now read-only.

Commit

Permalink
restart actions: on restart use data from previous run
Browse files Browse the repository at this point in the history
  • Loading branch information
DonHaul committed Aug 27, 2024
1 parent 739e9fd commit 39f3979
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion backoffice/backoffice/workflows/airflow_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ def restart_workflow_dags(workflow_id, workflow_type, params=None):
)


def delete_workflow_dag_runs(workflow_id, workflow_type):
def delete_workflow_dag_runs(workflow_id, workflow_type, params=None):
"""Deletes runs of a given workflow.
:param workflow_id: workflow_id for dags that should be restarted
Expand All @@ -181,6 +181,7 @@ def delete_workflow_dag_runs(workflow_id, workflow_type):

trigger_airflow_dag(
WORKFLOW_DAGS[workflow_type].initialize, str(workflow_id), params or data
)

return JsonResponse(
data={"message": f"Dag runs for worfklow {workflow_id} have been deleted"}
Expand Down

0 comments on commit 39f3979

Please sign in to comment.