ssh: handle concurrency issues for raw command execution (#6370)

* ssh: handle concurrency issues for raw command execution

* setup: bump sshfs
This commit is contained in:
Batuhan Taskaya
2021-07-29 14:40:49 +03:00
committed by GitHub
parent e3a541aa00
commit 9634efeb84
2 changed files with 5 additions and 2 deletions
+3
View File
@@ -110,6 +110,9 @@ class FSSpecWrapper(BaseFileSystem):
for file in self.find(path_info, **kwargs):
yield path_info.replace(path=file)
def move(self, from_info, to_info):
self.fs.move(self._with_bucket(from_info), self._with_bucket(to_info))
def remove(self, path_info):
self.fs.rm_file(self._with_bucket(path_info))
+2 -2
View File
@@ -101,7 +101,7 @@ s3 = ["s3fs==2021.7.0", "aiobotocore[boto3]>1.0.1"]
azure = ["adlfs==2021.7.1", "azure-identity>=1.4.0", "knack"]
# https://github.com/Legrandin/pycryptodome/issues/465
oss = ["ossfs==2021.7.5"]
ssh = ["sshfs>=2021.7.0"]
ssh = ["sshfs>=2021.7.1"]
# Remove the env marker if/when pyarrow is available for Python3.9
hdfs = ["pyarrow>=2.0.0"]
@@ -111,7 +111,7 @@ webdav = ["webdav4>=0.9.0"]
# for linux and mac, so it will fail to compile if user doesn't have all the
# requirements, including kerberos itself. Once all the wheels are available,
# we can start shipping it by default.
ssh_gssapi = ["sshfs[gssapi]>=2021.7.0"]
ssh_gssapi = ["sshfs[gssapi]>=2021.7.1"]
all_remotes = gs + s3 + azure + ssh + oss + gdrive + hdfs + webhdfs + webdav
tests_requirements = (