remove # in flow

basedosdados · Nov 13, 2024 · f2b7fb9 · f2b7fb9
1 parent 265c43d
commit f2b7fb9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pipelines/utils/crawler_anatel/telefonia_movel/flows.py b/pipelines/utils/crawler_anatel/telefonia_movel/flows.py
@@ -11,7 +11,7 @@
     get_max_date_in_table_microdados,
     get_year_full,
     get_semester,
-    #unzip,
+    unzip,
 )
 from pipelines.utils.constants import constants as utils_constants
 from pipelines.utils.decorators import Flow
@@ -59,8 +59,8 @@
     # Function dynamic parameters
     # https://discourse.prefect.io/t/my-parameter-value-shows-the-same-date-every-day-how-can-i-set-parameter-value-dynamically/99
     #####
-    # unzip_task = unzip()
-    new_year = get_year_full(ano)
+    unzip_task = unzip()
+    new_year = get_year_full(ano, upstream_tasks=[unzip_task])
     new_semester = get_semester(semestre, upstream_tasks=[new_year])
 
     update_tables = get_max_date_in_table_microdados(