diff --git a/dvc/remote/ssh/connection.py b/dvc/remote/ssh/connection.py index 6e49132b6..bfb058187 100644 --- a/dvc/remote/ssh/connection.py +++ b/dvc/remote/ssh/connection.py @@ -292,8 +292,9 @@ class SSHConnection: def open(self, *args, **kwargs): return self.sftp.open(*args, **kwargs) - def symlink(self, *args, **kwargs): - return self.sftp.symlink(*args, **kwargs) + def symlink(self, src, dest): + self.makedirs(posixpath.dirname(dest)) + self.sftp.symlink(src, dest) def reflink(self, src, dest): self.makedirs(posixpath.dirname(dest))