Fix mkdir in remote targets.
@@ -792,7 +792,7 @@ class RemoteFileSystem(FileSystem):
# create missing dirs
dst_dir = _local_fs.dirname(dst)
if dst_dir and not _local_fs.exists(dst_dir):
- _local_fs.mkdir(dst_dir, dir_perm=dir_perm, recursive=True)
+ _local_fs.mkdir(dst_dir, perm=dir_perm, recursive=True)
else:
rstat = self.exists(dst, stat=True)
if rstat and stat.S_ISDIR(rstat.st_mode):
@@ -802,7 +802,7 @@ class RemoteFileSystem(FileSystem):
# create missing dirs
dst_dir = self.dirname(dst)
if dst_dir and not self.exists(dst_dir):
- self.mkdir(dst_dir, dir_perm=dir_perm, recursive=True, **kwargs)
+ self.mkdir(dst_dir, perm=dir_perm, recursive=True, **kwargs)
# copy the file
return self._cached_copy(src, dst, cache=cache, validate=validate, **kwargs)
