bcode_server 0.0.1-alpha.0

Local bcode daemon runtime
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

//! Bounded fan-out materialization through canonical graph operations.
use super::{ServerError, representation};

pub(super) async fn advance(
    path: &std::path::Path,
    db: &dyn switchy_database::Database,
    authority: &bcode_workflow_store::WorkflowExecutionAuthority,
    run_id: &str,
    revision: u64,
    node_id: &str,
    activation_id: &str,
) -> Result<(bool, bool), ServerError> {
    let created = super::backpressure::queued(path, || {
        representation::graph::fanout::materialize(
            db,
            authority,
            run_id,
            node_id,
            activation_id,
            revision,
            32,
        )
    })
    .await
    .map_err(super::backpressure::normalize)?;
    let settled = super::backpressure::queued(path, || {
        representation::graph::fanout::settle(
            db,
            authority,
            run_id,
            node_id,
            activation_id,
            revision,
        )
    })
    .await
    .map_err(super::backpressure::normalize)?;
    let pending = super::backpressure::retry(|| {
        representation::graph::fanout_progress::pending(db, run_id, activation_id)
    })
    .await
    .map_err(super::backpressure::normalize)?;
    Ok((created > 0 || settled, pending))
}