From f60fb744e865020a5d76688dc3b946307ef4b4b9 Mon Sep 17 00:00:00 2001 From: Amisha Singla Date: Thu, 3 Oct 2024 21:13:42 -0500 Subject: [PATCH] lint update update --- airflow_variables_dev.json | 1 + dags/elementary_report_dag.py | 4 +++- .../build_elementary_slack_alert_task.py | 7 +------ 3 files changed, 5 insertions(+), 7 deletions(-) diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index 367e3228..00ecfcb9 100644 --- a/airflow_variables_dev.json +++ b/airflow_variables_dev.json @@ -344,6 +344,7 @@ "current_state": 720, "default": 60, "elementary_dbt_data_quality": 1620, + "elementary_generate_report": 60, "enriched_history_operations": 780, "enriched_history_operations_with_exclude": 780, "fee_stats": 840, diff --git a/dags/elementary_report_dag.py b/dags/elementary_report_dag.py index d94cb3ea..62710b13 100644 --- a/dags/elementary_report_dag.py +++ b/dags/elementary_report_dag.py @@ -27,6 +27,8 @@ ) as dag: # Trigger elementary - elementary_alerts = elementary_task(dag, "generate_report", resource_cfg="dbt",command="send-report") + elementary_alerts = elementary_task( + dag, "generate_report", resource_cfg="dbt", command="send-report" + ) elementary_alerts diff --git a/dags/stellar_etl_airflow/build_elementary_slack_alert_task.py b/dags/stellar_etl_airflow/build_elementary_slack_alert_task.py index 9d1839aa..3853cfc2 100644 --- a/dags/stellar_etl_airflow/build_elementary_slack_alert_task.py +++ b/dags/stellar_etl_airflow/build_elementary_slack_alert_task.py @@ -19,12 +19,7 @@ def access_secret(secret_name, namespace): return secret -def elementary_task( - dag, - task_name, - resource_cfg="default", - command="monitor" -): +def elementary_task(dag, task_name, resource_cfg="default", command="monitor"): namespace = conf.get("kubernetes", "NAMESPACE") if namespace == "default":