verifica alterações planejamento

prefeitura-rio · Nov 12, 2024 · 0ade9f3 · 0ade9f3
1 parent 59bbbb9
commit 0ade9f3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pipelines/treatment/monitoramento/flows.py b/pipelines/treatment/monitoramento/flows.py
@@ -14,6 +14,9 @@
 )
 from pipelines.schedules import cron_every_hour_minute_6
 from pipelines.treatment.monitoramento.constants import constants
+from pipelines.treatment.planejamento.constants import (
+    constants as planejamento_constants,
+)
 from pipelines.treatment.templates.flows import create_default_materialization_flow
 
 VIAGEM_INFORMADA_MATERIALIZACAO = create_default_materialization_flow(
@@ -29,6 +32,7 @@
     agent_label=smtr_constants.RJ_SMTR_AGENT_LABEL.value,
     wait=[
         constants.VIAGEM_INFORMADA_SELECTOR.value,
+        planejamento_constants.PLANEJAMENTO_DIARIO_SELECTOR.value,
         {
             "redis_key": f"{smtr_constants.GPS_SPPO_DATASET_ID.value}\
 .{smtr_constants.GPS_SPPO_TREATED_TABLE_ID.value}",