Update file dags.py

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",
   )