basedosdados / pipelines

🔀 Orquestrador de fluxos de captura, ingestão e tratamento de dados da BD
https://basedosdados.github.io/pipelines/
34 stars 13 forks source link

[fix] br_cgu_emendas_parlamentares #856

Closed tricktx closed 2 months ago

tricktx commented 2 months ago
  1. Adicionei o date_column no metadata para conseguir obter tabelas que só disponibilizam da coluna ano.
  2. Flow run SUCCESS
github-actions[bot] commented 2 months ago

Coverage

Tests Skipped Failures Errors Time
2 0 :zzz: 0 :x: 2 :fire: 1.322s :stopwatch:
tricktx commented 2 months ago

@laura-l-amaral

with case(update_metadata, True):
  update_django_metadata(
  dataset_id=dataset_id,
  table_id=table_id,
  date_format="%Y",
  date_column_name = {"year": "ano_emenda"},
  coverage_type="part_bdpro",
  time_delta =  {"years": 1},
  prefect_mode=materialization_mode,
  bq_project="basedosdados",
  upstream_tasks=[wait_for_materialization])