package bistro

You can search for identifiers within the package.

in-package search v0.2.0

A library to build and run distributed scientific workflows

Install

Dune Dependency

github.com Readme Edit opam file Versions (2)

Authors

P

Philippe Veber

Maintainers

P

philippe.veber@gmail.com

Sources

v0.5.0.tar.gz

md5=0ccb7c97728c94d17494b150192f6162

sha512=61dbd0ee5b98cd5fb8871d653aef0e440c318e9fbca439c3b0e4f86a32fa03c2a8a4770cd96b929b21b378db6788fa7d4df15935370be5b7b227564a31994998

doc/bistro.engine/Bistro_engine/Local_backend/index.html

Module `Bistro_engine.Local_backend`

type t = {

logger : Logger.t;
db : Db.t;
allocator : Allocator.t;

}

type token = unit

val create : 
  ?np:int ->
  ?mem:[ `GB of int ] ->
  ?loggers:
    < event : Db.t -> Logger.time -> Logger.event -> unit
      ; stop : unit Lwt.t.. >
      list ->
  Db.t ->
  t

val log : ?time:Logger.time -> t -> Logger.event -> unit

val run_shell_command : 'a -> unit -> Shell_command.t -> (int * bool) Lwt.t

val eval : 'a -> unit -> ('b -> 'c) -> 'b -> (unit, string) Core.result Lwt.t

val build_trace : 
  t ->
  'a Bistro_internals.Workflow.t ->
  Allocator.request ->
  (unit ->
    Allocator.resource ->
    (Task_result.t, Execution_trace.Set.t) Lwt_result.t) ->
  (Execution_trace.t, Execution_trace.Set.t) result Lwt.t

val stop : 'a -> unit Lwt.t