package bistro

  1. Overview
  2. Docs
module DAG : Bistro_tdag.Tdag_sig.S with type task = Task.t
type time = float
type event =
  1. | Init of {
    1. dag : DAG.t;
    2. needed : Task.t list;
    3. already_done : Task.t list;
    }
  2. | Task_ready of Task.t
  3. | Task_started of Task.t * Allocator.resource
  4. | Task_ended of Task.result
  5. | Task_skipped of Task.t * [ `Done_already | `Missing_dep | `Allocation_error of string ]
class type logger = object ... end
type trace =
  1. | Run of {
    1. ready : time;
    2. start : time;
    3. end_ : time;
    4. outcome : Task.result;
    }
  2. | Skipped of [ `Done_already | `Missing_dep | `Allocation_error of string ]
val compile : Bistro.any_workflow list -> DAG.t * Task.t list
val run : ?logger:logger -> ?goals:Task.t list -> Task.config -> Allocator.t -> DAG.t -> trace Core_kernel.Std.String.Map.t Lwt.t
OCaml

Innovation. Community. Security.