From b667bd151209def38432db64b830b44f62ab0c9a Mon Sep 17 00:00:00 2001
From: vtr363 <victor.m.rocha.vr@hotmail.com>
Date: Fri, 3 May 2024 17:22:05 -0300
Subject: [PATCH] descomenta recaptura e altera tabela

---
 .../dashboard_bilhetagem_madonna/flows.py     | 28 +++++++++----------
 1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py b/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py
index 3b0389f3e..6514566cb 100644
--- a/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py
+++ b/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py
@@ -63,20 +63,20 @@
 
     ## RECAPTURA ##
 
-    # run_recaptura_transacao = create_flow_run(
-    #     flow_name=bilhetagem_recaptura.name,
-    #     # project_name=emd_constants.PREFECT_DEFAULT_PROJECT.value,
-    #     project_name="staging",
-    #     labels=emd_constants.RJ_SMTR_AGENT_LABEL.value,
-    #     parameters=constants.BILHETAGEM_TRANSACAO_CAPTURE_PARAMS.value,
-    # )
+    run_recaptura_transacao = create_flow_run(
+        flow_name=bilhetagem_recaptura.name,
+        # project_name=emd_constants.PREFECT_DEFAULT_PROJECT.value,
+        project_name="staging",
+        labels=emd_constants.RJ_SMTR_AGENT_LABEL.value,
+        parameters=constants.BILHETAGEM_TRANSACAO_CAPTURE_PARAMS.value,
+    )
 
-    # wait_recaptura_transacao = wait_for_flow_run(
-    #     run_recaptura_transacao,
-    #     stream_states=True,
-    #     stream_logs=True,
-    #     raise_final_state=True,
-    # )
+    wait_recaptura_transacao = wait_for_flow_run(
+        run_recaptura_transacao,
+        stream_states=True,
+        stream_logs=True,
+        raise_final_state=True,
+    )
 
     ## MATERIALIZAÇÃO ##
 
@@ -102,7 +102,7 @@
     RUNS = run_dbt_model(
         dbt_client=dbt_client,
         dataset_id="dashboard_bilhetagem_madonna",
-        table_id="transacao_gentileza",
+        table_id="transacao_madonna",
         upstream=True,
     )