diff --git a/teste_dag.py b/teste_dag.py index 6bac0c8b09d24b3c75642ae6463fed8730d883ea..aaa690adcccbe604f5fb89003abb1d39c208de53 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -44,7 +44,7 @@ def process_records(): bash_command="dbt deps && dbt build", ) - task_spark() >> task_dbt_setup() >> task_bronze_to_gold() + task_spark >> task_dbt_setup >> task_bronze_to_gold dag = process_records()