jobflow_remote.remote package

Subpackages

• jobflow_remote.remote.host package
  • Submodules
    • jobflow_remote.remote.host.base module
      • BaseHost
      • HostError
    • jobflow_remote.remote.host.local module
      • LocalHost
    • jobflow_remote.remote.host.remote module
      • Interactive
      • InteractiveAuthStrategy
      • RemoteHost
      • inter_handler()
  • Module contents
    • BaseHost
      • BaseHost.close()
      • BaseHost.connect()
      • BaseHost.copy()
      • BaseHost.execute()
      • BaseHost.exists()
      • BaseHost.get()
      • BaseHost.interactive_login
      • BaseHost.is_connected
      • BaseHost.listdir()
      • BaseHost.mkdir()
      • BaseHost.put()
      • BaseHost.remove()
      • BaseHost.rmtree()
      • BaseHost.sanitize_command()
      • BaseHost.sanitize_output()
      • BaseHost.sanitize_regex
      • BaseHost.shell()
      • BaseHost.test()
      • BaseHost.write_text_file()
    • LocalHost
      • LocalHost.close()
      • LocalHost.connect()
      • LocalHost.copy()
      • LocalHost.execute()
      • LocalHost.exists()
      • LocalHost.get()
      • LocalHost.is_connected
      • LocalHost.listdir()
      • LocalHost.mkdir()
      • LocalHost.put()
      • LocalHost.remove()
      • LocalHost.rmtree()
      • LocalHost.shell()
      • LocalHost.write_text_file()
    • RemoteHost
      • RemoteHost.close()
      • RemoteHost.connect()
      • RemoteHost.connection
      • RemoteHost.copy()
      • RemoteHost.execute()
      • RemoteHost.exists()
      • RemoteHost.get()
      • RemoteHost.interactive_login
      • RemoteHost.is_connected
      • RemoteHost.listdir()
      • RemoteHost.mkdir()
      • RemoteHost.put()
      • RemoteHost.remove()
      • RemoteHost.rmtree()
      • RemoteHost.shell()
      • RemoteHost.write_text_file()

Submodules

• jobflow_remote.remote.data module
  • JOB_INIT_ARGS
  • MinimalFileStore
    • MinimalFileStore.close()
    • MinimalFileStore.connect()
    • MinimalFileStore.count()
    • MinimalFileStore.ensure_index()
    • MinimalFileStore.groupby()
    • MinimalFileStore.query()
    • MinimalFileStore.read_file()
    • MinimalFileStore.remove_docs()
    • MinimalFileStore.update()
    • MinimalFileStore.update_file()
  • MinimalMsgpackStore
    • MinimalMsgpackStore.name
    • MinimalMsgpackStore.read_file()
    • MinimalMsgpackStore.update_file()
  • MinimalMsgspecJSONStore
    • MinimalMsgspecJSONStore.name
    • MinimalMsgspecJSONStore.read_file()
    • MinimalMsgspecJSONStore.update_file()
  • MinimalORJSONStore
    • MinimalORJSONStore.name
    • MinimalORJSONStore.read_file()
    • MinimalORJSONStore.update_file()
  • StdJSONStore
  • check_additional_stores()
  • decode_datetime()
  • default_orjson_serializer()
  • encode_datetime()
  • get_job_path()
  • get_local_data_path()
  • get_remote_in_file()
  • get_remote_store()
  • get_remote_store_filenames()
  • get_single_store()
  • get_single_store_file_name()
  • get_store_file_paths()
  • resolve_job_dict_args()
  • update_store()
• jobflow_remote.remote.queue module
  • QueueManager
    • QueueManager.scheduler_io
    • QueueManager.host
    • QueueManager.cancel()
    • QueueManager.execute_cmd()
    • QueueManager.get_change_dir()
    • QueueManager.get_export()
    • QueueManager.get_job()
    • QueueManager.get_jobs_list()
    • QueueManager.get_modules()
    • QueueManager.get_post_run()
    • QueueManager.get_pre_run()
    • QueueManager.get_run_commands()
    • QueueManager.get_shell_manager()
    • QueueManager.get_submission_script()
    • QueueManager.submit()
    • QueueManager.write_submission_script()
  • set_name_out()

Module contents