diff --git a/python/pyarrow/fs.py b/python/pyarrow/fs.py index fe505530751..1b86e4b7e0f 100644 --- a/python/pyarrow/fs.py +++ b/python/pyarrow/fs.py @@ -263,7 +263,10 @@ def get_file_info_selector(self, selector): def create_dir(self, path, recursive): # mkdir also raises FileNotFoundError when base directory is not found - self.fs.mkdir(path, create_parents=recursive) + try: + self.fs.mkdir(path, create_parents=recursive) + except FileExistsError: + pass def delete_dir(self, path): self.fs.rm(path, recursive=True)