typo

prefeitura-rio · Nov 13, 2024 · 0283cb1 · 0283cb1
1 parent 1b08960
commit 0283cb1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pipelines/utils/gypscie/tasks.py b/pipelines/utils/gypscie/tasks.py
@@ -858,7 +858,7 @@ def timeout_flow(
         sleep(30)
 
 
-def monitor_flow(timeout_seconds, flow):
+def monitor_flow(timeout_seconds, flow_):
     """
     Tarefa de monitoramento paralela para interromper o fluxo
     se o tempo total ultrapassar o limite.
@@ -873,6 +873,6 @@ def monitor_flow(timeout_seconds, flow):
                 f"Tempo limite de {timeout_seconds} segundos excedido. Encerrando o fluxo."
             )
             logger.warning(stop_message)
-            flow.set_reference_tasks([Failed(stop_message)])  # Define o estado de falha do fluxo
+            flow_.set_reference_tasks([Failed(stop_message)])  # Define o estado de falha do fluxo
             return
         sleep(10)  # Verifica o tempo a cada 10 segundos