From d3d014bdc621900b1208b74063bf017ac15d02c9 Mon Sep 17 00:00:00 2001
From: edvs19 <edvs19@inf.ufpr.br>
Date: Thu, 6 Mar 2025 19:14:27 -0300
Subject: [PATCH] teste
---
teste_dag.py | 22 +++++++++++++---------
1 file changed, 13 insertions(+), 9 deletions(-)
diff --git a/teste_dag.py b/teste_dag.py
index faeb6ef..04b0585 100644
--- a/teste_dag.py
+++ b/teste_dag.py
@@ -31,16 +31,20 @@ with DAG(
packages="org.apache.hadoop:hadoop-aws:3.3.4"
)
- task_dbt_setup = BashOperator(
- task_id="dbt_setup",
- bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste",
- )
+ @task
+ def task_dbt_setup():
+ BashOperator(
+ task_id="dbt_setup",
+ bash_command=f"rm -rf /tmp/proj_teste && cp -r {repo_home}/proj_teste /tmp/proj_teste",
+ )
- task_bronze_to_gold = BashOperator(
- task_id="bronze_to_silver_to_gold",
- cwd="/tmp/proj_teste",
- bash_command="dbt deps && dbt build",
- )
+ @task
+ def task_bronze_to_gold():
+ BashOperator(
+ task_id="bronze_to_silver_to_gold",
+ cwd="/tmp/proj_teste",
+ bash_command="dbt deps && dbt build",
+ )
task_spark >> task_dbt_setup >> task_bronze_to_gold
--
GitLab