descomenta recaptura

prefeitura-rio · May 3, 2024 · 96b4279 · 96b4279
1 parent dda5291
commit 96b4279
Showing 1 changed file with 17 additions and 15 deletions.
diff --git a/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py b/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py
@@ -52,24 +52,26 @@
     default_parameters=bilhetagem_materializacao_madonna_parameters,
 )
 
+bilhetagem_materializacao_madonna.schedule = every_10_minutes
+
 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=LABELS,
-    #     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=LABELS,
+        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(