Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
update

update
  • Loading branch information
amishas157 committed Oct 4, 2024
1 parent d36a520 commit f60fb74
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 7 deletions.
1 change: 1 addition & 0 deletions airflow_variables_dev.json
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
4 changes: 3 additions & 1 deletion dags/elementary_report_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Original file line number Diff line number Diff line change
Expand Up @@ -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":
Expand Down

0 comments on commit f60fb74

Please sign in to comment.