dev: use inspect.iscoroutinefunction to thorough fix the await problem

fsspec · Dec 5, 2024 · b301ad5 · b301ad5
1 parent ce49c91
commit b301ad5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/ossfs/async_oss.py b/src/ossfs/async_oss.py
@@ -2,6 +2,7 @@
 Code of AioOSSFileSystem
 """
 import logging
+import inspect
 import os
 import weakref
 from datetime import datetime
@@ -156,7 +157,7 @@ async def _call_oss(
             if not method:
                 method = getattr(aiooss2, method_name)
                 logger.debug("CALL: %s - %s - %s", method.__name__, args, kwargs)
-                if method_name =="resumable_upload":
+                if inspect.iscoroutinefunction(method):
                     out = await method(service, *args, **kwargs)
                 else:
                     out = method(service, *args, **kwargs)