Airflow Variable usage example

datacoves · Feb 23, 2024 · e6dda6a · e6dda6a
1 parent a2a88de
commit e6dda6a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...estrate/dags/variables_and_connections.py → orchestrate/dags/variables.py b/...estrate/dags/variables_and_connections.py → orchestrate/dags/variables.py
@@ -9,13 +9,13 @@
     default_args={"start_date": "2021-01"},
     description="Loan Run",
     schedule_interval="0 0 1 */12 *",
-    tags=["version_5"],
+    tags=["version_1"],
     catchup=False,
 )
-def daily_loan_run():
+def variables_dag():
     transform = DatacovesDbtOperator(
         task_id="transform",
         bash_command=f"dbt build -s 'tag:{daily_run_tag}'",
     )
 
-dag = daily_loan_run()
+dag = variables_dag()