operon 0.7.0

A workflow engine for parallel, incremental scheduling of DAG-defined multiplex tasks.
Documentation 
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

[package]
name = "operon"
description = "A workflow engine for parallel, incremental scheduling of DAG-defined multiplex tasks."
version.workspace = true
authors.workspace = true
license.workspace = true
repository.workspace = true
readme.workspace = true
edition.workspace = true
rust-version.workspace = true
homepage.workspace = true
keywords = ["multidimensional", "workflow", "scheduler", "DAG"]
categories = ["asynchronous", "concurrency"]

[dependencies]
ansi_term = "0.12.1"
async-trait = "0.1.80"
bytes = "1"
chrono = "0.4.16"
clap = { version = "4.0.1", features = ["derive"] }
crossterm = { version = "0.29", features = ["event-stream"] }
csv = "1.2.1"
dashmap = "6"
deadpool-postgres = "0.14"
futures = "0.3"
indexmap = "2"
indoc = "2"
operon-macros.workspace = true
postgres-types = { version = "0.2.5", features = ["derive"] }
ratatui = "0.29"
secrecy = "0.10.1"
serde = { version = "1.0.113", features = ["derive"] }
serde_json = "1"
textwrap = "0.16"
thiserror = "2"
tracing = "0.1.37"
tracing-log = "0.2"
tracing-subscriber = { version = "0.3", features = ["registry"] }
tokio = { version = "1.37.0", features = ["full"] }
tokio-postgres = { version = "0.7.9", features = [
    "with-chrono-0_4",
    "with-serde_json-1",
    "with-uuid-1",
] }
tokio-util = { version = "0.7.12", features = ["rt"] }
twox-hash = { version = "2", default-features = false, features = [
    "std",
    "xxhash3_64",
] }
uuid = { version = "1", features = ["v4"] }

[target.'cfg(unix)'.dependencies]
nix = { version = "0.29", features = ["fs"] }

[dev-dependencies]
clap = { version = "4.0.1", features = ["env"] }
pretty_assertions = "1"
rstest = "0.26"
log = "0.4.17"
rand = "0.9"