From 3570e95ae0302f86ed64f985b866d7fa4237374d Mon Sep 17 00:00:00 2001 From: lcd22 <lcd22@inf.ufpr.br> Date: Thu, 6 Mar 2025 17:13:35 +0000 Subject: [PATCH] Update file dags.py --- dags.py | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/dags.py b/dags.py index 96db8a4..b320949 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", ) -- GitLab