hpcflow.sdk.core.execute.Executor#

class hpcflow.sdk.core.execute.Executor(cmd, env, package_name)#

Methods

`run`	Launch the subprocess to execute the commands, and once complete, stop the ZMQ server.
`send_abort`	Send an abort message to a running server.
`send_timeit`	Send orchestration timing from the child process to the main process.
`start_zmq_server`
`stop_zmq_server`

Attributes

`q`
`zmq_context`

run()#: Launch the subprocess to execute the commands, and once complete, stop the ZMQ server. Kill the subprocess if a “shutdown” or “abort” message is sent to the server.

classmethod send_abort(hostname, port_number)#: Send an abort message to a running server.

classmethod send_timeit(hostname, port_number, orchestration_time, work_time=None)#

Send orchestration timing from the child process to the main process.

work_time is e.g. for user script time, excluding orchestration around it.

start_zmq_server()#