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

for more information, see https://pre-commit.ci
prefeitura-rio · Oct 7, 2024 · 6fe1368 · 6fe1368
1 parent 70a303f
commit 6fe1368
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 7 deletions.
diff --git a/.github/workflows/scripts/register_flows.py b/.github/workflows/scripts/register_flows.py
@@ -91,7 +91,11 @@ def build_and_register(  # pylint: disable=too-many-branches
                 while attempts < max_retries:
                     attempts += 1
                     try:
-                        (flow_id, flow_version, is_new,) = register_serialized_flow(
+                        (
+                            flow_id,
+                            flow_version,
+                            is_new,
+                        ) = register_serialized_flow(
                             client=client,
                             serialized_flow=serialized_flow,
                             project_id=project_id,

diff --git a/pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py b/pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py
@@ -119,9 +119,9 @@ def download_and_save_local_from_ftp(file_info: dict, dataset_id: str = None, ta
     base_path = f'{os.getcwd()}/{os.getenv("DATA_FOLDER", "data")}/{{bucket_mode}}/{dataset_id}'
 
     # Set general local path to save file (bucket_modes: raw or staging)
-    file_info[
-        "local_path"
-    ] = f"""{base_path}/{table_id}/{file_info["partitions"]}/{file_info['filename']}.{{file_ext}}"""
+    file_info["local_path"] = (
+        f"""{base_path}/{table_id}/{file_info["partitions"]}/{file_info['filename']}.{{file_ext}}"""
+    )
 
     # Get raw data
     file_info["raw_path"] = file_info["local_path"].format(bucket_mode="raw", file_ext="txt")

diff --git a/pipelines/migration/projeto_subsidio_sppo/tasks.py b/pipelines/migration/projeto_subsidio_sppo/tasks.py
@@ -69,9 +69,9 @@ def subsidio_data_quality_check(
         request_params["dataset_id"] = constants.SUBSIDIO_SPPO_DASHBOARD_DATASET_ID.value
         if gte_result:
             request_params["dataset_id_v2"] = constants.SUBSIDIO_SPPO_DASHBOARD_V2_DATASET_ID.value
-            request_params[
-                "table_id_v2"
-            ] = constants.SUBSIDIO_SPPO_DASHBOARD_SUMARIO_TABLE_ID_V2.value
+            request_params["table_id_v2"] = (
+                constants.SUBSIDIO_SPPO_DASHBOARD_SUMARIO_TABLE_ID_V2.value
+            )
         else:
             request_params["dataset_id_v2"] = constants.SUBSIDIO_SPPO_DASHBOARD_DATASET_ID.value
             request_params["table_id_v2"] = constants.SUBSIDIO_SPPO_DASHBOARD_SUMARIO_TABLE_ID.value