[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci
prefeitura-rio · Nov 4, 2024 · df46c60 · df46c60
1 parent 0649aa0
commit df46c60
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 13 deletions.
diff --git a/pipelines/meteorologia/precipitacao_alertario/flows.py b/pipelines/meteorologia/precipitacao_alertario/flows.py
@@ -148,19 +148,13 @@
     #########################
 
     dfr_pluviometric, dfr_meteorological = download_data()
-    (
-        dfr_pluviometric,
-        empty_data_pluviometric,
-    ) = treat_pluviometer_and_meteorological_data(
+    (dfr_pluviometric, empty_data_pluviometric,) = treat_pluviometer_and_meteorological_data(
         dfr=dfr_pluviometric,
         dataset_id=DATASET_ID_PLUVIOMETRIC,
         table_id=TABLE_ID_PLUVIOMETRIC,
         mode=MATERIALIZATION_MODE,
     )
-    (
-        dfr_meteorological,
-        empty_data_meteorological,
-    ) = treat_pluviometer_and_meteorological_data(
+    (dfr_meteorological, empty_data_meteorological,) = treat_pluviometer_and_meteorological_data(
         dfr=dfr_meteorological,
         dataset_id=DATASET_ID_METEOROLOGICAL,
         table_id=TABLE_ID_METEOROLOGICAL,

diff --git a/pipelines/meteorologia/radar/mendanha/flows.py b/pipelines/meteorologia/radar/mendanha/flows.py
@@ -8,7 +8,8 @@
 from prefect.run_configs import KubernetesRun  # pylint: disable=E0611, E0401
 from prefect.storage import GCS  # pylint: disable=E0611, E0401
 from prefeitura_rio.pipelines_utils.custom import Flow  # pylint: disable=E0611, E0401
-  # pylint: disable=E0611, E0401
+
+# pylint: disable=E0611, E0401
 from prefeitura_rio.pipelines_utils.state_handlers import handler_inject_bd_credentials
 from prefeitura_rio.pipelines_utils.tasks import (  # pylint: disable=E0611, E0401
     create_table_and_upload_to_gcs,

diff --git a/pipelines/tasks.py b/pipelines/tasks.py
@@ -6,7 +6,7 @@
 
 import json
 from pathlib import Path
-from typing import List, Union, Tuple
+from typing import List, Tuple, Union
 
 import pandas as pd
 import pendulum  # pylint: disable=E0611, E0401

diff --git a/pipelines/utils/gypscie/tasks.py b/pipelines/utils/gypscie/tasks.py
@@ -707,9 +707,9 @@ def get_dataset_info(station_type: str, source: str) -> Dict:
         }
         if source == "alertario":
             dataset_info["table_id"] = "meteorologia_alertario"
-            dataset_info["destination_table_id"] = (
-                "preprocessamento_estacao_meteorologica_alertario"
-            )
+            dataset_info[
+                "destination_table_id"
+            ] = "preprocessamento_estacao_meteorologica_alertario"
         elif source == "inmet":
             dataset_info["table_id"] = "meteorologia_inmet"
             dataset_info["destination_table_id"] = "preprocessamento_estacao_meteorologica_inmet"