bijux-dag-runtime 0.4.1

Execution engine, replay semantics, and runtime policy layer for Bijux DAG graphs.
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

use serde_json::json;

pub fn node_eligible_events(
    node_ids: &[String],
    ts: u128,
    reason_code: &str,
    trigger_rule: &str,
) -> Vec<serde_json::Value> {
    node_ids
        .iter()
        .map(|node_id| {
            json!({
                "event": "node_ready",
                "ts": ts,
                "node_id": node_id,
                "reason": {
                    "code": reason_code,
                    "upstreams": [],
                    "trigger_rule": trigger_rule
                },
            })
        })
        .collect()
}

#[cfg(test)]
mod tests {
    use super::node_eligible_events;

    #[test]
    fn emits_one_event_per_node_with_stable_payload() {
        let node_ids = vec!["alpha".to_string(), "beta".to_string()];
        let events = node_eligible_events(&node_ids, 42, "root_ready", "all_success");
        assert_eq!(events.len(), 2);
        assert_eq!(events[0]["event"], "node_ready");
        assert_eq!(events[0]["ts"], 42);
        assert_eq!(events[0]["node_id"], "alpha");
        assert_eq!(events[0]["reason"]["code"], "root_ready");
        assert_eq!(events[0]["reason"]["trigger_rule"], "all_success");
        assert_eq!(events[1]["event"], "node_ready");
        assert_eq!(events[1]["ts"], 42);
        assert_eq!(events[1]["node_id"], "beta");
    }
}