Method build

core/src/orchestration/workflow.rs:152–166

Finalize the [`Workflow`], creating its event channel.

(self)

    /// Finalize the [`Workflow`], creating its event channel.
    pub fn build(self) -> Workflow {
        let (events, _) = broadcast::channel(DEFAULT_WORKFLOW_EVENT_CAPACITY);
        let root_id = self
            .root_id
            .unwrap_or_else(|| format!("wf-{}", uuid::Uuid::new_v4()));
        Workflow {
            executor: self.executor,
            store: self.store,
            events,
            step_events: self.step_events,
            root_id,
            phase_seq: Arc::new(AtomicUsize::new(0)),
            budget: self.budget,
        }
    }
}

/// A cheaply-clonable (all-`Arc`) typed orchestration facade.