diff --git a/pipelines/datasets/__init__.py b/pipelines/datasets/__init__.py index b2c3049a8..c913a822d 100644 --- a/pipelines/datasets/__init__.py +++ b/pipelines/datasets/__init__.py @@ -59,4 +59,5 @@ from pipelines.datasets.br_ms_sih.flows import * from pipelines.datasets.br_ms_sinan.flows import * from pipelines.datasets.br_cgu_emendas_parlamentares.flows import * -from pipelines.datasets.br_cgu_cartao_pagamento.flows import * \ No newline at end of file +from pipelines.datasets.br_cgu_cartao_pagamento.flows import * +from pipelines.datasets.br_tse_filiacao_partidaria.flows import * diff --git a/pipelines/datasets/br_tse_filiacao_partidaria/flows.py b/pipelines/datasets/br_tse_filiacao_partidaria/flows.py index bd45d4a0d..750d4fb88 100644 --- a/pipelines/datasets/br_tse_filiacao_partidaria/flows.py +++ b/pipelines/datasets/br_tse_filiacao_partidaria/flows.py @@ -36,7 +36,7 @@ ) with Flow( - name="br_tse_filiacao_partidaria", code_owners=["luiz"] + name="br_tse_filiacao_partidaria.microdados", code_owners=["luiz"] ) as br_tse_filiacao_partidaria_microdados: # Parameters @@ -97,7 +97,7 @@ current_flow_labels = get_current_flow_labels(upstream_tasks=[wait_upload_table]) materialization_flow = create_flow_run( flow_name=utils_constants.FLOW_EXECUTE_DBT_MODEL_NAME.value, - project_name=constants.PREFECT_STAGING_PROJECT.value, + project_name=constants.PREFECT_DEFAULT_PROJECT.value, parameters={ "dataset_id": dataset_id, "table_id": table_id,