diff --git a/pipelines/datasets/br_cvm_fi/flows.py b/pipelines/datasets/br_cvm_fi/flows.py index 4acaca4ea..55f0c0346 100644 --- a/pipelines/datasets/br_cvm_fi/flows.py +++ b/pipelines/datasets/br_cvm_fi/flows.py @@ -385,9 +385,14 @@ default=cvm_constants.URL_PERFIL_MENSAL.value, required=False, ) + arquivos = Parameter( + "arquivos", + default=["perfil_mensal_fi_202308.csv", "perfil_mensal_fi_202307.csv"], + required=False, + ) df = extract_links_and_dates(url) - arquivos = check_for_updates(df, upstream_tasks=[df]) + # arquivos = check_for_updates(df, upstream_tasks=[df]) with case(is_empty(arquivos), True): log_task(f"Não houveram atualizações em {url.default}!")