diff --git a/dags.py b/dags.py index 96db8a492da002f8ebf7d488d69d70847de1c77d..b320949b422684ddf49e438ae9389667a86123b5 100644 --- a/dags.py +++ b/dags.py @@ -22,12 +22,12 @@ def process_records(): ) task_2 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup1", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_3 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold1", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", ) @@ -39,12 +39,12 @@ def process_records(): ) task_5 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup2", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_6 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold2", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", ) @@ -57,12 +57,12 @@ def process_records(): task_8 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup3", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_9 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold3", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", ) @@ -76,12 +76,12 @@ def process_records(): task_11 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup4", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_12 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold4", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", ) @@ -93,12 +93,12 @@ def process_records(): ) task_14 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup5", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_15 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold5", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", ) @@ -110,12 +110,12 @@ def process_records(): ) task_17 = BashOperator( - task_id="dbt_setup", + task_id="dbt_setup6", bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste", ) task_18 = BashOperator( - task_id="bronze_to_silver_to_gold", + task_id="bronze_to_silver_to_gold6", cwd="/tmp/proj_teste", bash_command="dbt deps && dbt build", )