try to fix Python getting stuck during finalizer

See #63 for more details.

Author: skshetry

.github/workflows/test.yml

@@ -19,7 +19,7 @@ jobs:
 
       matrix:
         os: [ubuntu-latest, macos-latest]
-        pyv: ["3.8", "3.9", "3.10", "3.11.0-rc - 3.11", "3.12"]
+        pyv: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13", "3.14"]
 
     steps:
     - uses: actions/checkout@v4

setup.cfg

@@ -7,10 +7,13 @@ long_description_content_type = text/markdown
 classifiers =
     Development Status :: 4 - Beta
     Programming Language :: Python :: 3
-    Programming Language :: Python :: 3.7
     Programming Language :: Python :: 3.8
     Programming Language :: Python :: 3.9
     Programming Language :: Python :: 3.10
+    Programming Language :: Python :: 3.11
+    Programming Language :: Python :: 3.12
+    Programming Language :: Python :: 3.13
+    Programming Language :: Python :: 3.14
 
 [options]
 install_requires =

sshfs/spec.py

@@ -8,7 +8,13 @@
 
 import asyncssh
 from asyncssh.sftp import SFTPOpUnsupported
-from fsspec.asyn import AsyncFileSystem, async_methods, sync, sync_wrapper
+from fsspec.asyn import (
+    AsyncFileSystem,
+    FSTimeoutError,
+    async_methods,
+    sync,
+    sync_wrapper,
+)
 from fsspec.utils import infer_storage_options
 
 from sshfs.file import SSHFile
@@ -71,7 +77,12 @@ def __init__(
             **_client_args,
         )
         weakref.finalize(
-            self, sync, self.loop, self._finalize, self._pool, self._stack
+            self,
+            self._finalize,
+            self.loop,
+            self._client,
+            self._pool,
+            self._stack,
         )
 
     @classmethod
@@ -101,15 +112,34 @@ async def _connect(
     connect = sync_wrapper(_connect)
 
     @staticmethod
-    async def _finalize(pool, stack):
-        await pool.close()
-
-        # If an error occurs while the SSHFile is trying to
-        # open the native file, then the client might get broken
-        # due to partial initialization. We are just going to ignore
-        # the errors that arises on the finalization layer
-        with suppress(BrokenPipeError):
-            await stack.aclose()
+    def _finalize(loop, client, pool, stack):
+        async def close():
+            await pool.close()
+            # If an error occurs while the SSHFile is trying to
+            # open the native file, then the client might get broken
+            # due to partial initialization. We are just going to ignore
+            # the errors that arises on the finalization layer
+            with suppress(BrokenPipeError):
+                await stack.aclose()
+
+        if loop is not None and loop.is_running():
+            try:
+                loop = asyncio.get_running_loop()
+                loop.create_task(close())
+                return
+            except RuntimeError:
+                pass
+
+            try:
+                sync(loop, close, timeout=0.1)
+                return
+            except FSTimeoutError:
+                pass
+
+        try:
+            client.abort()  # try to abort the connection if no loop is running
+        except Exception:
+            pass
 
     @property
     def client(self):