Struct ChildWorkflowContext 

#[non_exhaustive]
pub struct ChildWorkflowContext {
    pub run_ctx: Arc<dyn RunContext>,
    pub extra_plugin_dirs: Vec<String>,
    pub workflow_run_id: String,
    pub model: Option<String>,
    pub exec_config: WorkflowExecConfig,
    pub inputs: HashMap<String, String>,
    pub event_sinks: Arc<[Arc<dyn EventSink>]>,
}

Subset of ExecutionState exposed to ChildWorkflowRunner implementations.

The full ExecutionState carries the engine’s mutable runtime — registries, accumulators, schema resolver, position pointer, cancellation token — none of which a harness needs to spawn a child workflow run. Passing it across the trait boundary makes every ExecutionState field rename or restructuring a breaking change for every ChildWorkflowRunner implementor.

ChildWorkflowContext is the narrow, stable surface: every field listed here is something the bridge actually reads when constructing the child run. Build via ExecutionState::child_workflow_context.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

run_ctx: Arc<dyn RunContext>

extra_plugin_dirs: Vec<String>

workflow_run_id: String

model: Option<String>

exec_config: WorkflowExecConfig

inputs: HashMap<String, String>

event_sinks: Arc<[Arc<dyn EventSink>]>

Implementations

impl ChildWorkflowContext

pub fn new( run_ctx: Arc<dyn RunContext>, extra_plugin_dirs: Vec<String>, workflow_run_id: String, model: Option<String>, exec_config: WorkflowExecConfig, inputs: HashMap<String, String>, event_sinks: Arc<[Arc<dyn EventSink>]>, ) -> Self

Examples found in repository

examples/logging_child_runner.rs (lines 93-101)

fn main() {
    let runner = LoggingChildRunner;
    let ctx = Arc::new(StubCtx(std::env::temp_dir()));
    let parent_ctx = ChildWorkflowContext::new(
        Arc::clone(&ctx) as Arc<dyn RunContext>,
        vec![],
        "parent-run-001".into(),
        None,
        WorkflowExecConfig::default(),
        HashMap::new(),
        Arc::from(vec![]),
    );
    let params = ChildWorkflowInput {
        inputs: HashMap::new(),
        iteration: 0,
        as_identity: None,
        depth: 1,
        parent_step_id: None,
        cancellation: CancellationToken::new(),
    };
    let result = runner
        .execute_child("child-workflow", &parent_ctx, params)
        .expect("execute_child failed");
    println!("succeeded: {}", result.all_succeeded);
}

Trait Implementations

impl Clone for ChildWorkflowContext

fn clone(&self) -> ChildWorkflowContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.