hypernets.dispatchers.process package

Subpackages

• hypernets.dispatchers.process.grpc package
  • Subpackages
    • hypernets.dispatchers.process.grpc.proto package
      • Submodules
      • hypernets.dispatchers.process.grpc.proto.proc_pb2 module
      • hypernets.dispatchers.process.grpc.proto.proc_pb2_grpc module
      • Module contents
  • Submodules
  • hypernets.dispatchers.process.grpc.process_broker_client module
  • hypernets.dispatchers.process.grpc.process_broker_service module
  • Module contents

Submodules

hypernets.dispatchers.process.grpc_process module

hypernets.dispatchers.process.local_process module

class hypernets.dispatchers.process.local_process.LocalProcess(cmd, in_file, out_file, err_file, environment=None)

Bases: multiprocessing.context.Process

exitcode

Return exit code of process or None if it has yet to stop

run(verbose=False)

Method to be run in sub-process; can be overridden in sub-class

hypernets.dispatchers.process.ssh_process module

class hypernets.dispatchers.process.ssh_process.DumpFileThread(in_file_handle, out_file_handle, buf_size=16)

Bases: threading.Thread

counter = <hypernets.utils.common.Counter object>

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

class hypernets.dispatchers.process.ssh_process.SshProcess(ssh_host, ssh_port, cmd, in_file, out_file, err_file, environment=None)

Bases: multiprocessing.context.Process

exitcode

Return exit code of process or None if it has yet to stop

run(verbose=False)

Method to be run in sub-process; can be overridden in sub-class

static ssh_run(ssh_host, ssh_port, cmd, in_file, out_file, err_file, environment)

Module contents