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

use bijux_dag_artifacts as _;
use bijux_dag_core as _;
use bijux_dag_runtime as _;
use ctrlc as _;
use hex as _;
use serde as _;
use serde_json as _;
use sha2 as _;
use tempfile as _;
use thiserror as _;

use bijux_dag_runtime::{dependency_resolution_is_complete, retry_allowed, RetryPolicySemantics};
use std::collections::BTreeSet;

#[test]
fn node_execution_requires_dependencies_and_retry_budget() {
    let retry =
        RetryPolicySemantics { max_attempts: 2, initial_backoff_ms: 10, exponential: false };
    assert!(retry_allowed(1, &retry));
    assert!(!retry_allowed(2, &retry));

    let resolved = BTreeSet::from(["extract".to_string(), "transform".to_string()]);
    assert!(dependency_resolution_is_complete(
        &["extract".to_string(), "transform".to_string()],
        &resolved
    ));
}