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

* ssh: handle concurrency issues for raw command execution

* setup: bump sshfs

dvc/fs/fsspec_wrapper.py

@@ -110,6 +110,9 @@ def walk_files(self, path_info, **kwargs):
         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))
 

setup.py

@@ -101,7 +101,7 @@ def run(self):
 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 @@ def run(self):
 # 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 = (