From a449316fe13933f4960a235c96546d35cf2afe52 Mon Sep 17 00:00:00 2001
From: Rafael Carvalho Pinheiro <74972217+pixuimpou@users.noreply.github.com>
Date: Thu, 20 Jun 2024 18:05:31 -0300
Subject: [PATCH] =?UTF-8?q?Migra=C3=A7=C3=A3o=20-=20Desliga=20schedule=20b?=
 =?UTF-8?q?r=5Frj=5Friodejaneiro=5Frecursos=20(#707)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

desliga schedule
---
 .../rj_smtr/br_rj_riodejaneiro_recursos/flows.py    | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py
index 78769da39..2d61faa03 100644
--- a/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py
+++ b/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py
@@ -27,7 +27,8 @@
 from pipelines.rj_smtr.tasks import get_current_timestamp
 
 from pipelines.rj_smtr.flows import default_capture_flow, default_materialization_flow
-from pipelines.rj_smtr.schedules import every_day
+
+# from pipelines.rj_smtr.schedules import every_day
 
 
 # CAPTURA DOS TICKETS #
@@ -106,9 +107,11 @@
     ]
 
     table_params = task(
-        lambda tables, exclude: [t for t in tables if t["table_id"] not in exclude]
-        if exclude is not None
-        else tables,
+        lambda tables, exclude: (
+            [t for t in tables if t["table_id"] not in exclude]
+            if exclude is not None
+            else tables
+        ),
         checkpoint=False,
         name="get_tables_to_run",
     )(tables=constants.SUBSIDIO_SPPO_RECURSOS_TABLE_IDS.value, exclude=exclude)
@@ -197,4 +200,4 @@
 )
 
 # Schedule
-subsidio_sppo_recurso.schedule = every_day
+# subsidio_sppo_recurso.schedule = every_day