sig
type run_parameters
val name : string
val serialize : run_parameters -> string
val deserialize_exn : string -> run_parameters
val start :
run_parameters ->
host_io:Host_io.t ->
(run_parameters, Host_io.Error.classified) Unix_io.Deferred_result.t
val update :
run_parameters ->
host_io:Host_io.t ->
([ `Failed of run_parameters * string
| `Still_running of run_parameters
| `Succeeded of run_parameters ], Host_io.Error.classified)
Unix_io.Deferred_result.t
val kill :
run_parameters ->
host_io:Host_io.t ->
([ `Killed of run_parameters ], Host_io.Error.classified)
Unix_io.Deferred_result.t
val log :
run_parameters -> (string * Ketrew_pure.Internal_pervasives.Log.t) list
val additional_queries :
run_parameters -> (string * Ketrew_pure.Internal_pervasives.Log.t) list
val query :
run_parameters ->
host_io:Host_io.t ->
string ->
(string, Ketrew_pure.Internal_pervasives.Log.t) Unix_io.Deferred_result.t
val create :
?host:Ketrew_pure.Host.t ->
?queue:string ->
?name:string ->
?wall_limit:string ->
?processors:[ `Min of int | `Min_max of int * int ] ->
?project:string ->
?request_memory:[ `GB of int | `MB of int ] ->
?raw_options:string list ->
Ketrew_pure.Program.t -> [> `Long_running of string * string ]
end