diff --git a/teste_dag.py b/teste_dag.py index 1bee801da89cbac77ab60d3d686ece6eb18a1c8f..c0380851edc40d892146f216ac0fc9727216cbaa 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -48,5 +48,7 @@ def process_records(): task2 = task_dbt_setup() task3 = task_bronze_to_gold() + task1 >> task2 >> task3 + dag = process_records()