style: format code

Author: observerw

src/lsp_client/client/abc.py

@@ -82,7 +82,7 @@ async def _run_server(
             errors: list[ServerRuntimeError] = []
             for server in self._iter_candidate_servers():
                 try:
-                    async with server.run(self.get_workspace(), sender=sender) as s:  # ty: ignore[invalid-argument-type]
+                    async with server.run(self._workspace, sender=sender) as s:  # ty: ignore[invalid-argument-type]
                         yield s, receiver
                         return
                 except ServerRuntimeError as e:

src/lsp_client/server/local.py

@@ -38,25 +38,22 @@ class LocalServer(Server):
 
     ensure_installed: EnsureInstalledProtocol | None = None
 
-    _process: Process | None = field(init=False, default=None)
+    _process: Process = field(init=False, default=None)
 
     @cached_property
     def stdin(self) -> AnyByteSendStream:
-        assert self._process, "Process is not started"
         stdin = self._process.stdin
         assert stdin, "Process stdin is not available"
         return stdin
 
     @cached_property
     def stdout(self) -> BufferedByteReceiveStream:
-        assert self._process, "Process is not started"
         stdout = self._process.stdout
         assert stdout, "Process stdout is not available"
         return BufferedByteReceiveStream(stdout)
 
     @cached_property
     def stderr(self) -> BufferedByteReceiveStream:
-        assert self._process, "Process is not started"
         stderr = self._process.stderr
         assert stderr, "Process stderr is not available"
         return BufferedByteReceiveStream(stderr)
@@ -117,6 +114,9 @@ async def run_process(self, workspace: Workspace) -> AsyncGenerator[None]:
             raise ServerRuntimeError(self, "Failed to start server process") from e
         finally:
             try:
+                if self._process.returncode is None:
+                    self._process.terminate()
+
                 with anyio.fail_after(self.shutdown_timeout):
                     if (returncode := await self._process.wait()) != 0:
                         logger.warning("Process exited with code {}", returncode)