calypso.dispatchers.orchestrator.executor package

calypso.dispatchers.orchestrator.executor.get_executor(name: str, executor_dict: dict) → BaseExecutor

Submodules

• calypso.dispatchers.orchestrator.executor.base_executor module
  • BaseExecutor
    • BaseExecutor.download_job()
    • BaseExecutor.download_remote_file()
    • BaseExecutor.execute()
    • BaseExecutor.files_exist()
    • BaseExecutor.get_remote_file_obj()
    • BaseExecutor.locally_rglob()
    • BaseExecutor.make_remote_dir()
    • BaseExecutor.read_remote_file()
    • BaseExecutor.rglob()
    • BaseExecutor.upload_file_to_remote()
    • BaseExecutor.upload_job()
    • BaseExecutor.write_into_remote_file()
• calypso.dispatchers.orchestrator.executor.local module
  • Local
    • Local.download_job()
    • Local.download_remote_file()
    • Local.execute()
    • Local.files_exist()
    • Local.get_remote_file_obj()
    • Local.make_remote_dir()
    • Local.read_remote_file()
    • Local.rglob()
    • Local.upload_file_to_remote()
    • Local.upload_job()
    • Local.write_into_remote_file()
• calypso.dispatchers.orchestrator.executor.ssh module
  • SSHClient
    • SSHClient.connect()
    • SSHClient.disconnect()
    • SSHClient.download_file()
    • SSHClient.execute_command()
    • SSHClient.file_exist()
    • SSHClient.files_exist()
    • SSHClient.get_file_obj()
    • SSHClient.mkdir()
    • SSHClient.read_file()
    • SSHClient.remote_rglob()
    • SSHClient.upload_file()
    • SSHClient.write_file()
  • SSHExecutor
    • SSHExecutor.download_job()
    • SSHExecutor.download_remote_file()
    • SSHExecutor.execute()
    • SSHExecutor.files_exist()
    • SSHExecutor.get_remote_file_obj()
    • SSHExecutor.locally_files_exist()
    • SSHExecutor.locally_rglob()
    • SSHExecutor.make_remote_dir()
    • SSHExecutor.read_remote_file()
    • SSHExecutor.remote_file_exist()
    • SSHExecutor.rglob()
    • SSHExecutor.upload_file_to_remote()
    • SSHExecutor.upload_job()
    • SSHExecutor.write_into_remote_file()