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