fix: un-awaited method

fsspec · Dec 5, 2024 · ce49c91 · ce49c91
1 parent 3bac1f5
commit ce49c91
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/ossfs/async_oss.py b/src/ossfs/async_oss.py
@@ -156,7 +156,10 @@ async def _call_oss(
             if not method:
                 method = getattr(aiooss2, method_name)
                 logger.debug("CALL: %s - %s - %s", method.__name__, args, kwargs)
-                out = method(service, *args, **kwargs)
+                if method_name =="resumable_upload":
+                    out = await method(service, *args, **kwargs)
+                else:
+                    out = method(service, *args, **kwargs)
             else:
                 logger.debug("CALL: %s - %s - %s", method.__name__, args, kwargs)
                 out = await method(*args, **kwargs)