Format codebase

Author: Aksem

extensions/fine_agent_pi/fine_agent_pi/install_pi_handler.py

@@ -61,7 +61,9 @@ async def run(
             except (OSError, icommandrunner.CommandNotLaunchableError) as error:
                 self.logger.error(f"Install failed: {error}")
                 return SetupSystemRunResult(
-                    failed=[f"{_TOOL_NAME}: {backend_support.spawn_error(cmd[0], error)}"]
+                    failed=[
+                        f"{_TOOL_NAME}: {backend_support.spawn_error(cmd[0], error)}"
+                    ]
                 )
             await process.wait_for_end()
             await progress.advance(1)

extensions/fine_agent_pi/fine_agent_pi/install_pi_packages_handler.py

@@ -350,7 +350,9 @@ async def run(
         if installed_sources:
             check_cmd = ["pi", "list", "--approve"]
             try:
-                check_process = await self.command_runner.run(check_cmd, cwd=cwd, env=env)
+                check_process = await self.command_runner.run(
+                    check_cmd, cwd=cwd, env=env
+                )
             except (OSError, icommandrunner.CommandNotLaunchableError) as error:
                 self.logger.warning(backend_support.spawn_error(check_cmd[0], error))
                 return SetupSystemRunResult(failed=failed)

extensions/fine_python_pip/tests/test_install_deps_in_env_handler.py

@@ -78,7 +78,7 @@ def test_pip_cmd_argv_is_exact() -> None:
         "-e",
         "file:///D:/a/pkg[a]",
         "other>=1.0",
-        "pkg ; python_version < \"3.12\"",
+        'pkg ; python_version < "3.12"',
     ]
 
 

extensions/fine_python_ruff/tests/test_lsp_fix_applicability.py

@@ -66,9 +66,7 @@ def __init__(self, output: str) -> None:
         self._output = output
         self.commands: list[list[str]] = []
 
-    async def run(
-        self, cmd: icommandrunner.Argv, cwd=None, env=None
-    ):
+    async def run(self, cmd: icommandrunner.Argv, cwd=None, env=None):
         icommandrunner.check_argv(cmd)
         self.commands.append(list(cmd))
         return _StubProcess(self._output)

finecode_extension_api/src/finecode_extension_api/interfaces/icommandrunner.py

@@ -204,4 +204,4 @@ def run_sync(
         same refusals and `OSError` on an unstartable program — minus the
         process-group option.
         """
-        ...
+        ...

finecode_extension_api/tests/test_lsp_service.py

@@ -420,13 +420,9 @@ async def test_file_open_event_sends_utf8_file_content_in_did_open(
     file_path.write_bytes(_NON_ASCII.encode("utf-8"))
 
     async with _running_service(file_path, _NON_ASCII) as (service, session, _):
-        await service._handle_file_event(
-            ifileeditor.FileOpenEvent(file_path=file_path)
-        )
+        await service._handle_file_event(ifileeditor.FileOpenEvent(file_path=file_path))
 
-    did_open = [
-        n for n in session.notifications if n.method == "textDocument/didOpen"
-    ]
+    did_open = [n for n in session.notifications if n.method == "textDocument/didOpen"]
     assert len(did_open) == 1
     assert did_open[0].params["textDocument"]["text"] == _NON_ASCII
 

finecode_extension_runner/tests/test_command_runner_argv.py

@@ -16,13 +16,12 @@
 from pathlib import Path
 
 import pytest
-
 from finecode_extension_api.interfaces import icommandrunner
 
 from finecode_extension_runner.impls.command_runner import (
-    _prepare_argv,
     CommandRunner,
     CommandRunnerConfig,
+    _prepare_argv,
 )
 from finecode_extension_runner.process_slots import ProcessSlots
 
@@ -77,7 +76,12 @@ def _runner_with_slots() -> tuple[CommandRunner, ProcessSlots]:
 async def test_arguments_arrive_verbatim() -> None:
     """The point of exec: nothing reinterpreted, nothing quoted away."""
     process = await _runner().run(
-        [sys.executable, "-c", "import json,sys; print(json.dumps(sys.argv[1:]))", *_ARGS]
+        [
+            sys.executable,
+            "-c",
+            "import json,sys; print(json.dumps(sys.argv[1:]))",
+            *_ARGS,
+        ]
     )
     await process.wait_for_end()
 
@@ -86,7 +90,12 @@ async def test_arguments_arrive_verbatim() -> None:
 
 def test_run_sync_arguments_arrive_verbatim() -> None:
     process = _runner().run_sync(
-        [sys.executable, "-c", "import json,sys; print(json.dumps(sys.argv[1:]))", *_ARGS]
+        [
+            sys.executable,
+            "-c",
+            "import json,sys; print(json.dumps(sys.argv[1:]))",
+            *_ARGS,
+        ]
     )
     process.wait_for_end()
 
@@ -267,4 +276,4 @@ def explode(*args: object, **kwargs: object) -> str | None:
         platform="linux",
         which=explode,
     )
-    assert argv == ["npm", "install"]
+    assert argv == ["npm", "install"]

finecode_extension_runner/tests/test_command_runner_concurrency.py

@@ -43,10 +43,14 @@ async def test_second_run_does_not_spawn_until_first_process_exits() -> None:
     )
     loop = asyncio.get_running_loop()
 
-    task1 = asyncio.create_task(runner.run([sys.executable, "-c", "import time; time.sleep(0.3)"]))
+    task1 = asyncio.create_task(
+        runner.run([sys.executable, "-c", "import time; time.sleep(0.3)"])
+    )
     # Give task1 a head start so it acquires the slot first.
     await asyncio.sleep(0.05)
-    task2 = asyncio.create_task(runner.run([sys.executable, "-c", "import time; time.sleep(0.01)"]))
+    task2 = asyncio.create_task(
+        runner.run([sys.executable, "-c", "import time; time.sleep(0.01)"])
+    )
 
     start1 = loop.time()
     proc1 = await task1
@@ -107,9 +111,13 @@ async def test_configured_limit_still_caps_below_the_gate() -> None:
     )
     loop = asyncio.get_running_loop()
 
-    task1 = asyncio.create_task(runner.run([sys.executable, "-c", "import time; time.sleep(0.2)"]))
+    task1 = asyncio.create_task(
+        runner.run([sys.executable, "-c", "import time; time.sleep(0.2)"])
+    )
     await asyncio.sleep(0.05)
-    task2 = asyncio.create_task(runner.run([sys.executable, "-c", "import time; time.sleep(0.01)"]))
+    task2 = asyncio.create_task(
+        runner.run([sys.executable, "-c", "import time; time.sleep(0.01)"])
+    )
 
     start2 = loop.time()
     proc2 = await task2

finecode_extension_runner/tests/test_command_runner_teardown.py

@@ -23,7 +23,6 @@
 )
 from finecode_extension_runner.process_slots import ProcessSlots
 
-
 # Process groups, `killpg`/`SIGKILL` and `os.kill(pid, 0)` (which is
 # `CTRL_C_EVENT` on Windows) are all POSIX-only.
 pytestmark = pytest.mark.skipif(
@@ -168,8 +167,7 @@ async def test_is_alive_tracks_the_group_after_a_forking_launcher_exits() -> Non
     # instead -- it is set the moment the launcher itself dies.
     deadline = asyncio.get_running_loop().time() + 5.0
     while (
-        process.get_exit_code() is None
-        and asyncio.get_running_loop().time() < deadline
+        process.get_exit_code() is None and asyncio.get_running_loop().time() < deadline
     ):
         await asyncio.sleep(0.05)
 

finecode_extension_runner/tests/test_file_manager.py

@@ -9,7 +9,6 @@
 
 from finecode_extension_runner.impls.file_manager import FileManager
 
-
 # Em dash, right double quote, é and 😀 — no newline, so the byte assertions
 # below do not depend on Windows \n→\r\n translation. The right double quote
 # (U+201D) and 😀 are outside cp1252, so a cp1252 read raises instead of