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

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
Co-authored-by: Harris Tzovanakis <[email protected]>
  • Loading branch information
DonHaul and drjova authored Jul 30, 2024
1 parent db49239 commit f7c9b3d
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions backoffice/backoffice/workflows/airflow_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ def restart_failed_tasks(workflow_id, workflow_type):


def find_executed_dags(workflow_id, workflow_type):
"""For a given workflow find dags associated to it
"""For a given workflow find dags associated to it.
:param workflow: workflow to look dags for
:returns: dictionary with executed dags and their status
Expand All @@ -108,7 +108,7 @@ def find_executed_dags(workflow_id, workflow_type):


def find_failed_dag(workflow_id, workflow_type):
"""For a given workflow find failed dags
"""For a given workflow find failed dags.
:param workflow: workflow to get failed dags
:returns: failed dag id or none
Expand All @@ -122,7 +122,8 @@ def find_failed_dag(workflow_id, workflow_type):


def delete_workflow_dag(dag_id, workflow_id):
"""Delete dag run
"""Delete dag run.
:param dag_id: dag to be removed
:param workflow: workflow with the dag execution to be deleted
:returns: request response
Expand Down

0 comments on commit f7c9b3d

Please sign in to comment.