M : sig ... endval spawn_worker : ?where:[ `Local | `Remote of _ Remote_executable.t ] ‑> ?disown:bool ‑> ?env:(string * string) list ‑> ?rpc_max_message_size:int ‑> ?rpc_handshake_timeout:Core.Time.Span.t ‑> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ‑> ?connection_timeout:Core.Time.Span.t ‑> ?cd:string ‑> ?umask:int ‑> redirect_stdout:Fd_redirection.t ‑> redirect_stderr:Fd_redirection.t ‑> M.worker_arg ‑> on_failure:(Core.Error.t ‑> unit) ‑> (M.worker_ret * worker_id) Core.Or_error.t Async.Deferred.tval spawn_worker_exn : ?where:[ `Local | `Remote of _ Remote_executable.t ] ‑> ?disown:bool ‑> ?env:(string * string) list ‑> ?rpc_max_message_size:int ‑> ?rpc_handshake_timeout:Core.Time.Span.t ‑> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ‑> ?connection_timeout:Core.Time.Span.t ‑> ?cd:string ‑> ?umask:int ‑> redirect_stdout:Fd_redirection.t ‑> redirect_stderr:Fd_redirection.t ‑> M.worker_arg ‑> on_failure:(Core.Error.t ‑> unit) ‑> (M.worker_ret * worker_id) Async.Deferred.tval kill_worker : worker_id ‑> unit Core.Or_error.t Async.Deferred.tval run : ?rpc_max_message_size:int ‑> ?rpc_handshake_timeout:Core.Time.Span.t ‑> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ‑> ?where_to_listen:Async.Tcp.Where_to_listen.inet ‑> Async.Command.t ‑> unit