diff --git a/fsspec/asyn.py b/fsspec/asyn.py index c27df1c2f..d1b8b33a6 100644 --- a/fsspec/asyn.py +++ b/fsspec/asyn.py @@ -226,6 +226,8 @@ async def _throttled_gather(coros, batch_size=None, **gather_kwargs): "_find", "_du", "_size", + "_mkdir", + "_makedirs", ] @@ -624,6 +626,12 @@ async def _expand_path(self, path, recursive=False, maxdepth=None): raise FileNotFoundError(path) return list(sorted(out)) + async def _mkdir(self, path, create_parents=True, **kwargs): + pass # not necessary to implement, may not have directories + + async def _makedirs(self, path, exist_ok=False): + pass # not necessary to implement, may not have directories + def mirror_sync_methods(obj): """Populate sync and async methods for obj