package bistro

  1. Overview
  2. Docs
A library to build and run distributed scientific workflows

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (2)

Authors

  1. P
    Philippe Veber

Maintainers

  1. P
    philippe.veber@gmail.com

Sources

bistro-0.6.0.tbz
sha256=146177faaaa9117a8e2bf0fd60cb658662c0aa992f35beb246e6fd0766050e66
sha512=553fe0c20f236316449b077a47e6e12626d193ba1916e9da233e5526dd39090e8677277e1c79baace3bdc940cb009f25431730a8efc00ae4ed9cc42a0add9609

doc/bistro.internals/Bistro_internals/Workflow/index.html

Module Bistro_internals.WorkflowSource

Sourcetype path =
  1. | FS_path of string
  2. | Cache_id of string
  3. | Cd of path * string list
Sourceval cd : path -> string list -> path
Sourcemodule Docker_image : sig ... end
Sourcemodule Singularity_image : sig ... end
Sourcetype container_image =
  1. | Docker_image of Docker_image.t
  2. | Singularity_image of Singularity_image.t
Sourceval docker_image : ?tag:string -> ?registry:string -> account:string -> name:string -> unit -> container_image
Sourcetype _ t =
  1. | Pure : {
    1. id : string;
    2. value : 'a;
    } -> 'a t
  2. | App : {
    1. id : string;
    2. f : ('a -> 'b) t;
    3. x : 'a t;
    } -> 'b t
  3. | Both : {
    1. id : string;
    2. fst : 'a t;
    3. snd : 'b t;
    } -> ('a * 'b) t
  4. | List : {
    1. id : string;
    2. elts : 'a t list;
    } -> 'a list t
  5. | Eval_path : {
    1. id : string;
    2. workflow : path t;
    } -> string t
  6. | Spawn : {
    1. id : string;
    2. elts : 'a list t;
    3. f : 'a t -> 'b t;
    4. deps : any list;
    } -> 'b list t
  7. | List_nth : {
    1. id : string;
    2. elts : 'a list t;
    3. index : int;
    } -> 'a t
  8. | Input : {
    1. id : string;
    2. path : string;
    3. version : int option;
    } -> path t
  9. | Select : {
    1. id : string;
    2. dir : path t;
    3. sel : string list;
    } -> path t
  10. | Plugin : ('a plugin, any) step -> 'a t
  11. | Shell : (shell_command, any) step -> path t
  12. | Glob : {
    1. id : string;
    2. pattern : string option;
    3. type_selection : [ `File | `Directory ] option;
    4. dir : path t;
    } -> path list t
  13. | Trywith : {
    1. id : string;
    2. w : 'a t;
    3. failsafe : 'a t;
    } -> 'a t
  14. | Ifelse : {
    1. id : string;
    2. cond : bool t;
    3. _then_ : 'a t;
    4. _else_ : 'a t;
    } -> 'a t
Sourceand ('a, 'b) step = {
  1. id : string;
  2. descr : string;
  3. task : 'a;
  4. np : int;
    (*

    Required number of processors

    *)
  5. mem : int t option;
    (*

    Required memory in MB

    *)
  6. version : int option;
    (*

    Version number of the wrapper

    *)
  7. deps : 'b list;
}
Sourceand 'a plugin =
  1. | Value_plugin : (unit -> 'a) t -> 'a plugin
  2. | Path_plugin : (string -> unit) t -> path plugin
Sourceand shell_command = {
  1. cmd : token Command.t;
  2. images : container_image list;
}
Sourceand token =
  1. | Path_token of path t
  2. | Path_list_token of {
    1. elts : path list t;
    2. sep : string;
    3. quote : char option;
    }
  3. | String_token of string t
Sourceand any =
  1. | Any : _ t -> any
Sourceval digest : 'a -> string
Sourceval id : 's. 's t -> string
Sourceval any : 'a t -> any
Sourceval compare_token : token -> token -> int
Sourcemodule Any : sig ... end
Sourceval input : ?version:int -> string -> path t
Sourceval select : path t -> string list -> path t
Sourceval pure : id:string -> 'a -> 'a t
Sourceval data : 'a -> 'a t
Sourceval int : 'a -> 'a t
Sourceval string : 'a -> 'a t
Sourceval app : ('a -> 'b) t -> 'a t -> 'b t
Sourceval ($) : ('a -> 'b) t -> 'a t -> 'b t
Sourceval both : 'a t -> 'b t -> ('a * 'b) t
Sourceval add_mem_dep : 'a t option -> any list -> any list
Sourceval plugin : ?descr:string -> ?np:int -> ?mem:int t -> ?version:int -> (unit -> 'a) t -> 'a t
Sourceval path_plugin : ?descr:string -> ?np:int -> ?mem:int t -> ?version:int -> (string -> unit) t -> path t
Sourceval path : path t -> string t
Sourceval digestible_cmd : token Command.t -> string Command.t
Sourceval shell : ?descr:string -> ?mem:int t -> ?np:int -> ?version:int -> ?img:container_image list -> token Command.t list -> path t
Sourceval list : 'a t list -> 'a list t
Sourceval independent_workflows_aux : (bool * Any.Set.t) Any.Map.t -> Any.Map.key -> from:any -> (bool * Any.Set.t) Any.Map.t
Sourceval independent_workflows : Any.Map.key -> from:any -> Any.Set.elt list
Sourceval spawn : 'a list t -> f:('a t -> 'b t) -> 'b list t
Sourceval list_nth : 'a list t -> int -> 'a t
Sourceval glob : ?pattern:string -> ?type_selection:[ `Directory | `File ] -> path t -> path list t
Sourceval trywith : 'a t -> 'a t -> 'a t
Sourceval ifelse : bool t -> 'a t -> 'a t -> 'a t