Merge pull request #602 from prefeitura-rio/staging/cor-richard

Changing parameters on cemaden and redemet flow
prefeitura-rio · Dec 18, 2023 · d0f1e2c · d0f1e2c
2 parents 6fc5bd2 + 1eb23dd
commit d0f1e2c
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/pipelines/rj_cor/meteorologia/meteorologia_redemet/flows.py b/pipelines/rj_cor/meteorologia/meteorologia_redemet/flows.py
@@ -51,12 +51,12 @@
 
     # Materialization parameters
     MATERIALIZE_AFTER_DUMP = Parameter(
-        "materialize_after_dump", default=False, required=False
+        "materialize_after_dump", default=True, required=False
     )
     MATERIALIZE_TO_DATARIO = Parameter(
-        "materialize_to_datario", default=False, required=False
+        "materialize_to_datario", default=True, required=False
     )
-    MATERIALIZATION_MODE = Parameter("mode", default="dev", required=False)
+    MATERIALIZATION_MODE = Parameter("mode", default="prod", required=False)
 
     # Dump to GCS after? Should only dump to GCS if materializing to datario
     DUMP_TO_GCS = Parameter("dump_to_gcs", default=False, required=False)

diff --git a/pipelines/rj_cor/meteorologia/meteorologia_redemet/schedules.py b/pipelines/rj_cor/meteorologia/meteorologia_redemet/schedules.py
@@ -1,7 +1,7 @@
 # -*- coding: utf-8 -*-
 """
 Schedules for meteorologia_redemet
-Rodar a cada 1 hora
+Dados são atualizados a cada 1 hora
 """
 from datetime import timedelta, datetime
 from prefect.schedules import Schedule
@@ -11,8 +11,8 @@
 hour_schedule = Schedule(
     clocks=[
         IntervalClock(
-            interval=timedelta(days=30),
-            start_date=datetime(2023, 1, 1, 0, 12, 0),
+            interval=timedelta(minutes=60),
+            start_date=datetime(2023, 1, 1, 0, 10, 0),
             labels=[
                 constants.RJ_COR_AGENT_LABEL.value,
             ],

diff --git a/pipelines/rj_cor/meteorologia/precipitacao_cemaden/flows.py b/pipelines/rj_cor/meteorologia/precipitacao_cemaden/flows.py
@@ -52,12 +52,12 @@
     TABLE_ID = Parameter("table_id", default="taxa_precipitacao_cemaden", required=True)
     # Materialization parameters
     MATERIALIZE_AFTER_DUMP = Parameter(
-        "materialize_after_dump", default=False, required=False
+        "materialize_after_dump", default=True, required=False
     )
     MATERIALIZE_TO_DATARIO = Parameter(
-        "materialize_to_datario", default=False, required=False
+        "materialize_to_datario", default=True, required=False
     )
-    MATERIALIZATION_MODE = Parameter("mode", default="dev", required=False)
+    MATERIALIZATION_MODE = Parameter("mode", default="prod", required=False)
     TRIGGER_RAIN_DASHBOARD_UPDATE = Parameter(
         "trigger_rain_dashboard_update", default=False, required=False
     )