Merge pull request #882 from basedosdados/staging/fix-cgu-servidores

[refactor] br_cgu_servidores_executivo_federal
basedosdados · Nov 21, 2024 · d73e56d · d73e56d
2 parents d8c2cf9 + 33723b9
commit d73e56d
Show file tree

Hide file tree

Showing 11 changed files with 773 additions and 1,090 deletions.
diff --git a/pipelines/datasets/br_cgu_cartao_pagamento/flows.py b/pipelines/datasets/br_cgu_cartao_pagamento/flows.py
@@ -10,21 +10,21 @@
     every_day_microdados_governo_federal
 )
 
-br_cgu_cartao_pagamento__governo_federal = deepcopy(flow_cgu_cartao_pagamento)
+br_cgu_cartao_pagamento__governo_federal = copy(flow_cgu_cartao_pagamento)
 br_cgu_cartao_pagamento__governo_federal.name = "br_cgu_cartao_pagamento.governo_federal"
 br_cgu_cartao_pagamento__governo_federal.code_owners = ["trick"]
 br_cgu_cartao_pagamento__governo_federal.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_cgu_cartao_pagamento__governo_federal.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
 br_cgu_cartao_pagamento__governo_federal.schedule = every_day_microdados_governo_federal
 
-br_cgu_cartao_pagamento__defesa_civil = deepcopy(flow_cgu_cartao_pagamento)
+br_cgu_cartao_pagamento__defesa_civil = copy(flow_cgu_cartao_pagamento)
 br_cgu_cartao_pagamento__defesa_civil.name = "br_cgu_cartao_pagamento.defesa_civil"
 br_cgu_cartao_pagamento__defesa_civil.code_owners = ["trick"]
 br_cgu_cartao_pagamento__defesa_civil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_cgu_cartao_pagamento__defesa_civil.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
 br_cgu_cartao_pagamento__defesa_civil.schedule = every_day_microdados_defesa_civil
 
-br_cgu_cartao_pagamento__compras_centralizadas = deepcopy(flow_cgu_cartao_pagamento)
+br_cgu_cartao_pagamento__compras_centralizadas = copy(flow_cgu_cartao_pagamento)
 br_cgu_cartao_pagamento__compras_centralizadas.name = "br_cgu_cartao_pagamento.compras_centralizadas"
 br_cgu_cartao_pagamento__compras_centralizadas.code_owners = ["trick"]
 br_cgu_cartao_pagamento__compras_centralizadas.storage = GCS(constants.GCS_FLOWS_BUCKET.value)

diff --git a/pipelines/datasets/br_cgu_servidores_executivo_federal/constants.py b/pipelines/datasets/br_cgu_servidores_executivo_federal/constants.py