diff --git a/fsspec/implementations/asyn_wrapper.py b/fsspec/implementations/asyn_wrapper.py index 43604a28c..f58b0b612 100644 --- a/fsspec/implementations/asyn_wrapper.py +++ b/fsspec/implementations/asyn_wrapper.py @@ -57,8 +57,9 @@ def _wrap_all_sync_methods(self): """ Wrap all synchronous methods of the underlying filesystem with asynchronous versions. """ + excluded_methods = {"open"} for method_name in dir(self.sync_fs): - if method_name.startswith("_"): + if method_name.startswith("_") or method_name in excluded_methods: continue attr = inspect.getattr_static(self.sync_fs, method_name)