chore: add funcionarios_ativos saude to materialization

prefeitura-rio · Oct 4, 2024 · 9cfedac · 9cfedac
1 parent 932d170
commit 9cfedac
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 13 deletions.
diff --git a/pipelines/ergon/materializa_funcionarios_saude/flows.py b/pipelines/ergon/materializa_funcionarios_saude/flows.py
@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 """
-DBT-related flows for EGPWeb Dashboard de Metas
+Materialize Active SMS Employees from Ergon
 """
 
 from copy import deepcopy

diff --git a/pipelines/ergon/materializa_funcionarios_saude/schedules.py b/pipelines/ergon/materializa_funcionarios_saude/schedules.py
@@ -12,17 +12,19 @@
 
 from pipelines.constants import constants
 
-smfp_funcionarios_saude_clocks = IntervalClock(
-    interval=timedelta(days=1),
-    start_date=datetime(2021, 11, 23, 14, 0, tzinfo=pytz.timezone("America/Sao_Paulo")),
-    labels=[
-        constants.RJ_SMFP_AGENT_LABEL.value,
-    ],
-    parameter_defaults={
-        "dataset_id": "recursos_humanos_ergon_saude",
-        "table_id": "funcionarios_ativos",
-    },
-)
+smfp_funcionarios_saude_clocks = [
+    IntervalClock(
+        interval=timedelta(days=1),
+        start_date=datetime(2021, 11, 23, 14, 0, tzinfo=pytz.timezone("America/Sao_Paulo")),
+        labels=[
+            constants.RJ_SMFP_AGENT_LABEL.value,
+        ],
+        parameter_defaults={
+            "dataset_id": "recursos_humanos_ergon_saude",
+            "table_id": "funcionarios_ativos",
+        },
+    )
+]
 smfp_funcionarios_saude_daily_update_schedule = Schedule(
     clocks=untuple(smfp_funcionarios_saude_clocks)
 )
diff --git a/pipelines/templates/run_dbt_model/flows.py b/pipelines/templates/run_dbt_model/flows.py
@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 """
-MATERIALIZA MODELOS DO DBT.......
+MATERIALIZA MODELOS DO DBT.........
 """
 
 from copy import deepcopy