teste atualização estações

pipelines/rj_cor/meteorologia/meteorologia_redemet/flows.py

@@ -17,6 +17,7 @@
     download,
     tratar_dados,
     salvar_dados,
+    tratar_dados_estacao,
 )
 from pipelines.rj_cor.meteorologia.meteorologia_redemet.schedules import hour_schedule
 from pipelines.utils.decorators import Flow

pipelines/rj_cor/meteorologia/meteorologia_redemet/tasks.py

@@ -239,17 +239,16 @@ def tratar_dados_estacao(data_inicio: str, data_fim: str) -> pd.DataFrame:
     # Função para converter longitude de graus, minutos, segundos para decimal
     res_data["latitude"] = res_data["lat"].apply(converter_lat_lon)
     res_data["longitude"] = res_data["lon"].apply(converter_lat_lon)
-    return dados
-
-
-
+    return res_data
+
+
 def converter_lat_lon(longitude_str):
     longitude_str = longitude_str.replace("º", "/").replace("''", "/").replace("'", "/")
-    
+
     # Divida a string com base nos espaços em branco
     partes = longitude_str.split("/")
     # print(partes)
-    
+
     # Extraia os graus, minutos e segundos da lista de partes
     graus = int(partes[0])
     minutos = int(partes[1])
@@ -262,5 +261,5 @@ def converter_lat_lon(longitude_str):
     # Verifique se a direção é Norte (N) e retorne o valor decimal
     if ("W" in partes[3].upper()) | ("S" in partes[3].upper()):
         decimal = -decimal
-    
-    return decimal
+
+    return decimal