descomenta recaptura

prefeitura-rio · May 3, 2024 · f818334 · f818334
1 parent 7536a47
commit f818334
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py b/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py
@@ -58,21 +58,21 @@
 with Flow("SMTR: Bilhetagem Madonna - Tratamento") as bilhetagem_madonna:
     LABELS = get_current_flow_labels()
 
-    # # 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,
-    # )
-
-    # wait_recaptura_transacao = wait_for_flow_run(
-    #     run_recaptura_transacao,
-    #     stream_states=True,
-    #     stream_logs=True,
-    #     raise_final_state=True,
-    # )
+    # 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,
+    )
+
+    wait_recaptura_transacao = wait_for_flow_run(
+        run_recaptura_transacao,
+        stream_states=True,
+        stream_logs=True,
+        raise_final_state=True,
+    )
 
     # Materialização
     run_materializacao_madonna = create_flow_run(