run pre-commit

Author: yashgorana

.github/workflows/e2e-tests.yaml

@@ -18,8 +18,7 @@ jobs:
     strategy:
       max-parallel: 99
       matrix:
-        e2e-test:
-          [
+        e2e-test: [
             "basic_aggregator",
             "model_aggregator",
             "aggregator_with_local_training",
@@ -33,7 +32,6 @@ jobs:
     # runs-on: ${{ matrix.runner }}
     runs-on: ${{ matrix.os }}
     steps:
-
       - name: Free Disk Space
         run: |
           sudo rm -rf /Users/runner/Library/Android/sdk || true

notebooks/02-trade-code.ipynb

@@ -176,9 +176,7 @@
    "source": [
     "# TEMP bug where we cant use theirs_with_my_read because the parent write is ignored but allowing the perm file to set its own\n",
     "# rules wont work either so we need to solve the permissioning of files themselves\n",
-    "path = myanalysis.to_flow(\n",
-    "    client_config=client_config, inputs={\"trade_data\": trade_data}\n",
-    ")\n",
+    "path = myanalysis.to_flow(client_config=client_config, inputs={\"trade_data\": trade_data})\n",
     "path"
    ]
   },

notebooks/03-netflix-code.ipynb

@@ -347,15 +347,10 @@
     "        non_zero_indices = np.nonzero(tv_count_array)[0].astype(int)\n",
     "        non_zero_values = tv_count_array[non_zero_indices].astype(int)\n",
     "        outer_part = counter * slice_size\n",
-    "        non_zero_dict = {\n",
-    "            int(k + outer_part): int(v)\n",
-    "            for k, v in dict(zip(non_zero_indices, non_zero_values)).items()\n",
-    "        }\n",
+    "        non_zero_dict = {int(k + outer_part): int(v) for k, v in dict(zip(non_zero_indices, non_zero_values)).items()}\n",
     "        tmdb_id_value_counts.update(non_zero_dict)\n",
     "        counter += 1\n",
-    "        stats[\"value_counts\"] = dict(\n",
-    "            sorted(tmdb_id_value_counts.items(), key=lambda item: item[1], reverse=True)\n",
-    "        )\n",
+    "        stats[\"value_counts\"] = dict(sorted(tmdb_id_value_counts.items(), key=lambda item: item[1], reverse=True))\n",
     "    return stats\n",
     "\n",
     "\n",
@@ -380,13 +375,9 @@
     "    top_5_summary = {}\n",
     "    top_5_summary[\"avg_time\"] = round(all_results[\"total_time\"] / num_parties)\n",
     "    top_5_summary[\"avg_views\"] = round(all_results[\"total_views\"] / num_parties)\n",
-    "    top_5_summary[\"avg_unique_show_views\"] = round(\n",
-    "        all_results[\"total_unique_show_views\"] / num_parties\n",
-    "    )\n",
+    "    top_5_summary[\"avg_unique_show_views\"] = round(all_results[\"total_unique_show_views\"] / num_parties)\n",
     "    top_5_summary[\"top_5\"] = dict(\n",
-    "        sorted(\n",
-    "            all_results[\"value_counts\"].items(), key=lambda item: item[1], reverse=True\n",
-    "        )[:top_k]\n",
+    "        sorted(all_results[\"value_counts\"].items(), key=lambda item: item[1], reverse=True)[:top_k]\n",
     "    )\n",
     "    return top_5_summary\n",
     "\n",

syftbox/client/utils/file_manager.py

@@ -92,11 +92,9 @@ def _convert_to_windows_path(folder_path: str) -> str:
     """
     try:
         # Use wslpath to convert the path
-        result = subprocess.run(
-            ["wslpath", "-w", folder_path], capture_output=True, text=True, check=True
-        )
+        result = subprocess.run(["wslpath", "-w", folder_path], capture_output=True, text=True, check=True)
         return result.stdout.strip()
-    except Exception as e:
+    except Exception:
         return ""
 
 

tests/e2e/test_aggregator_with_local_training.py

@@ -1,14 +1,13 @@
 import asyncio
 import json
-import os
 import secrets
 import shutil
 from pathlib import Path
 
 import pytest
 from loguru import logger
 
-from tests.e2e.conftest import Client, E2EContext, Server, E2ETimeoutError
+from tests.e2e.conftest import Client, E2EContext, E2ETimeoutError, Server
 
 AGGREGATOR_CONFIG = {
     "participants": ["[email protected]", "[email protected]", "[email protected]"],
@@ -123,7 +122,7 @@ async def test_e2e_aggregator_with_local_training(e2e_context: E2EContext):
     agg_private_dir.mkdir(parents=True, exist_ok=True)
     agg_priv_data_path = agg_private_dir / "mnist_dataset.pt"
     test_dataset_path = agg_client.api_path(AGGREGATOR_API_NAME) / "samples" / "test_data" / "mnist_dataset.pt"
-    with open(test_dataset_path, 'rb') as src, open(agg_priv_data_path, 'wb') as dst:
+    with open(test_dataset_path, "rb") as src, open(agg_priv_data_path, "wb") as dst:
         shutil.copyfileobj(src, dst)
     await verify_file_sizes(test_dataset_path, agg_priv_data_path)
     await e2e_context.wait_for_path(agg_priv_data_path, timeout=60, interval=1)