From 9cfedacab929efe041c711097da616ef848e4f5f Mon Sep 17 00:00:00 2001 From: d116626 Date: Fri, 4 Oct 2024 12:44:30 -0300 Subject: [PATCH] chore: add funcionarios_ativos saude to materialization --- .../materializa_funcionarios_saude/flows.py | 2 +- .../schedules.py | 24 ++++++++++--------- pipelines/templates/run_dbt_model/flows.py | 2 +- 3 files changed, 15 insertions(+), 13 deletions(-) diff --git a/pipelines/ergon/materializa_funcionarios_saude/flows.py b/pipelines/ergon/materializa_funcionarios_saude/flows.py index 8702df9..b2f8ed9 100644 --- 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 index 583e62f..06bbc05 100644 --- 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 index c54e77f..3f22c2f 100644 --- 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