From 58ea62504e789d115f156c6d530ee378b4f268fd Mon Sep 17 00:00:00 2001 From: pixuimpou <74972217+pixuimpou@users.noreply.github.com> Date: Thu, 20 Jun 2024 21:09:38 +0000 Subject: [PATCH] =?UTF-8?q?Deploying=20to=20gh-pages=20from=20@=20prefeitu?= =?UTF-8?q?ra-rio/pipelines@a449316fe13933f4960a235c96546d35cf2afe52=20?= =?UTF-8?q?=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../br_rj_riodejaneiro_recursos/flows.html | 19 +++++++++++++------ 1 file changed, 13 insertions(+), 6 deletions(-) diff --git a/rj_smtr/br_rj_riodejaneiro_recursos/flows.html b/rj_smtr/br_rj_riodejaneiro_recursos/flows.html index fc2e4d77e..41aadfe7a 100644 --- a/rj_smtr/br_rj_riodejaneiro_recursos/flows.html +++ b/rj_smtr/br_rj_riodejaneiro_recursos/flows.html @@ -56,7 +56,8 @@
pipelines.rj_smtr.br_rj_riodejaneiro_recursos.flo
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 #
@@ -135,9 +136,11 @@ Module pipelines.rj_smtr.br_rj_riodejaneiro_recursos.flo
]
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)
@@ -226,7 +229,7 @@ Module pipelines.rj_smtr.br_rj_riodejaneiro_recursos.flo
)
# Schedule
-subsidio_sppo_recurso.schedule = every_day
+# subsidio_sppo_recurso.schedule = every_day
@@ -245,7 +248,11 @@ Functions
Expand source code
-lambda tables, exclude: [t for t in tables if t["table_id"] not in exclude]
+lambda tables, exclude: (
+ [t for t in tables if t["table_id"] not in exclude]
+ if exclude is not None
+ else tables
+),