Stone_Red/dvc
1
0
Fork 0
mirror of https://github.com/Stone-Red-Code/dvc.git synced 2026-11-02 07:18:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

ssh: implement interface for fs related operations

Browse Source
This commit is contained in:
Mr. Outis
2019-08-24 00:16:37 -05:00
parent d13b5a14f8
commit 1be63dd93e
1 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dvc/remote/ssh/__init__.py
+33
View File
@@ -176,6 +176,18 @@ class RemoteSSH(RemoteBASE):
with self.ssh(path_info) as ssh:
return ssh.isdir(path_info.path)
def isfile(self, path_info):
with self.ssh(path_info) as ssh:
return ssh.isfile(path_info.path)
def getsize(self, path_info):
with self.ssh(path_info) as ssh:
return ssh.getsize(path_info.path)
def open(self, path_info, mode="r", encoding=None):
with self.ssh(path_info) as ssh:
return ssh.open(path_info.path, mode=mode, encoding=encoding)
def copy(self, from_info, to_info):
if from_info.scheme != self.scheme or to_info.scheme != self.scheme:
raise NotImplementedError
@@ -183,6 +195,27 @@ class RemoteSSH(RemoteBASE):
with self.ssh(from_info) as ssh:
ssh.cp(from_info.path, to_info.path)
def symlink(self, from_info, to_info):
if from_info.scheme != self.scheme or to_info.scheme != self.scheme:
raise NotImplementedError
with self.ssh(from_info) as ssh:
ssh.symlink(from_info.path, to_info.path)
def hardlink(self, from_info, to_info):
if from_info.scheme != self.scheme or to_info.scheme != self.scheme:
raise NotImplementedError
with self.ssh(from_info) as ssh:
ssh.hardlink(from_info.path, to_info.path)
def reflink(self, from_info, to_info):
if from_info.scheme != self.scheme or to_info.scheme != self.scheme:
raise NotImplementedError
with self.ssh(from_info) as ssh:
ssh.reflink(from_info.path, to_info.path)
def remove(self, path_info):
if path_info.scheme != self.scheme:
raise NotImplementedError