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":