From abdb18dac4c76b7fdac3ac573fcf0b682659c907 Mon Sep 17 00:00:00 2001 From: Luiz Eduardo Date: Thu, 17 Oct 2024 15:44:12 -0300 Subject: [PATCH] Registrar flow --- pipelines/datasets/__init__.py | 3 ++- pipelines/datasets/br_tse_filiacao_partidaria/flows.py | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) 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,