Registrar flow

basedosdados · Oct 17, 2024 · abdb18d · abdb18d
1 parent 4a0a044
commit abdb18d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git 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 *
+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
@@ -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,