Remove use of asyncio API deprecated in python 3.14 (#1862)

* replace deprecated asyncio.iscoroutinefunction with inspect

Author: braingram

fsspec/asyn.py

@@ -7,7 +7,6 @@
 import os
 import re
 import threading
-from contextlib import contextmanager
 from glob import has_magic
 from typing import TYPE_CHECKING, Iterable
 
@@ -120,18 +119,6 @@ def wrapper(*args, **kwargs):
     return wrapper
 
 
-@contextmanager
-def _selector_policy():
-    original_policy = asyncio.get_event_loop_policy()
-    try:
-        if os.name == "nt" and hasattr(asyncio, "WindowsSelectorEventLoopPolicy"):
-            asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
-
-        yield
-    finally:
-        asyncio.set_event_loop_policy(original_policy)
-
-
 def get_loop():
     """Create or return the default fsspec IO loop
 
@@ -142,8 +129,7 @@ def get_loop():
             # repeat the check just in case the loop got filled between the
             # previous two calls from another thread
             if loop[0] is None:
-                with _selector_policy():
-                    loop[0] = asyncio.new_event_loop()
+                loop[0] = asyncio.new_event_loop()
                 th = threading.Thread(target=loop[0].run_forever, name="fsspecIO")
                 th.daemon = True
                 th.start()

fsspec/implementations/asyn_wrapper.py

@@ -82,7 +82,7 @@ def _wrap_all_sync_methods(self):
                 continue
 
             method = getattr(self.sync_fs, method_name)
-            if callable(method) and not asyncio.iscoroutinefunction(method):
+            if callable(method) and not inspect.iscoroutinefunction(method):
                 async_method = async_wrapper(method, obj=self)
                 setattr(self, f"_{method_name}", async_method)
 

fsspec/tests/test_async.py

@@ -1,7 +1,6 @@
 import asyncio
 import inspect
 import io
-import os
 import time
 
 import pytest
@@ -131,25 +130,6 @@ async def main(**kwargs):
     assert sum(asyncio.run(main())) == 32  # override
 
 
-@pytest.mark.skipif(os.name != "nt", reason="only for windows")
-def test_windows_policy():
-    from asyncio.windows_events import SelectorEventLoop
-
-    loop = fsspec.asyn.get_loop()
-    policy = asyncio.get_event_loop_policy()
-
-    # Ensure that the created loop always uses selector policy
-    assert isinstance(loop, SelectorEventLoop)
-
-    # Ensure that the global policy is not changed and it is
-    # set to the default one. This is important since the
-    # get_loop() method will temporarily override the policy
-    # with the one which uses selectors on windows, so this
-    # check ensures that we are restoring the old policy back
-    # after our change.
-    assert isinstance(policy, asyncio.DefaultEventLoopPolicy)
-
-
 def test_running_async():
     assert not fsspec.asyn.running_async()