Transport: support OpenSSH (aiidateam#6795)

fix conflicts

fix tests

fix copy function

Author: khsrali

src/aiida/engine/daemon/execmanager.py

@@ -34,6 +34,7 @@
 from aiida.orm.utils.log import get_dblogger_extra
 from aiida.repository.common import FileType
 from aiida.schedulers.datastructures import JobState
+from aiida.transports import has_magic
 
 if TYPE_CHECKING:
     from aiida.transports import Transport
@@ -465,7 +466,7 @@ async def stash_calculation(calculation: CalcJobNode, transport: Transport) -> N
         target_basepath = target_base / uuid[:2] / uuid[2:4] / uuid[4:]
 
         for source_filename in source_list:
-            if transport.has_magic(source_filename):
+            if has_magic(source_filename):
                 copy_instructions = []
                 for globbed_filename in await transport.glob_async(source_basepath / source_filename):
                     target_filepath = target_basepath / Path(globbed_filename).relative_to(source_basepath)
@@ -679,7 +680,7 @@ async def retrieve_files_from_list(
         if isinstance(item, (list, tuple)):
             tmp_rname, tmp_lname, depth = item
             # if there are more than one file I do something differently
-            if transport.has_magic(tmp_rname):
+            if has_magic(tmp_rname):
                 remote_names = await transport.glob_async(workdir.joinpath(tmp_rname))
                 local_names = []
                 for rem in remote_names:
@@ -702,7 +703,7 @@ async def retrieve_files_from_list(
         else:
             abs_item = item if item.startswith('/') else str(workdir.joinpath(item))
 
-            if transport.has_magic(abs_item):
+            if has_magic(abs_item):
                 remote_names = await transport.glob_async(abs_item)
                 local_names = [os.path.split(rem)[1] for rem in remote_names]
             else:

src/aiida/schedulers/plugins/bash.py

@@ -32,6 +32,7 @@ def submit_job(self, working_directory: str, filename: str) -> str | ExitCode:
         result = self.transport.exec_command_wait(
             self._get_submit_command(escape_for_bash(filename)), workdir=working_directory
         )
+
         return self._parse_submit_output(*result)
 
     def get_jobs(

src/aiida/tools/pytest_fixtures/orm.py

@@ -216,7 +216,7 @@ def factory(label: str | None = None, configure: bool = True) -> 'Computer':
         computer = aiida_computer(label=label, hostname='localhost', transport_type='core.ssh_async')
 
         if configure:
-            computer.configure()
+            computer.configure(backend='asyncssh')
 
         return computer
 

src/aiida/transports/plugins/__init__.py

@@ -12,9 +12,12 @@
 
 # fmt: off
 
+from .async_backend import *
 from .ssh import *
 
 __all__ = (
+    'AsyncSSH',
+    'OpenSSH',
     'SshTransport',
     'convert_to_bool',
     'parse_sshconfig',