From f818334612bbff3de20243c9e06c9f9e82ac9ddc Mon Sep 17 00:00:00 2001 From: vtr363 Date: Fri, 3 May 2024 12:55:15 -0300 Subject: [PATCH] descomenta recaptura --- .../dashboard_bilhetagem_madonna/flows.py | 30 +++++++++---------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py b/pipelines/rj_smtr/dashboard_bilhetagem_madonna/flows.py index 43d7e0c0f..72e17aed7 100644 --- 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(