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

bistro-0.6.0.tbz

sha256=146177faaaa9117a8e2bf0fd60cb658662c0aa992f35beb246e6fd0766050e66

sha512=553fe0c20f236316449b077a47e6e12626d193ba1916e9da233e5526dd39090e8677277e1c79baace3bdc940cb009f25431730a8efc00ae4ed9cc42a0add9609

doc/src/bistro.engine/logger.ml.html

Source file `logger.ml`

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
open Bistro_internals

type time = float

type event =
  | Workflow_ready : _ Workflow.t -> event
  | Workflow_started : _ Workflow.t * Allocator.resource -> event
  | Workflow_ended : {
      details : Execution_trace.Run_details.t ;
      start : time ;
      _end_ : time ;
    } -> event
  | Workflow_skipped : _ Workflow.t * [ `Done_already | `Missing_dep ] -> event
  | Workflow_allocation_error : _ Workflow.t * string -> event
  | Workflow_collected : _ Workflow.t -> event
  | Singularity_image_collected : Workflow.container_image -> event
  | Debug : string -> event

class type t = object
  method event : Db.t -> time -> event -> unit
  method stop : unit Lwt.t
end

let null = object
  method event _ _ _ = ()
  method stop = Lwt.return ()
end

let tee loggers = object
  method event x y z =
    List.iter (fun l -> l#event x y z) loggers

  method stop =
    Lwt.join (List.map (fun l -> l#stop) loggers)
end