descomenta recaptura e altera tabela

prefeitura-rio · May 3, 2024 · b667bd1 · b667bd1
1 parent 83705d4
commit b667bd1
Showing 1 changed file with 14 additions and 14 deletions.
diff --git 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,
     )