Struct Subgraph 

pub struct Subgraph {
    pub workflow_id: WorkflowId,
    pub run_id: RunId,
    pub dag: Dag<Arc<dyn StatefulStep>>,
    pub schema: Arc<StateSchema>,
    pub checkpointer: Arc<dyn Checkpointer>,
    pub input_channels: Vec<String>,
    pub output_channels: Vec<String>,
}

Subgraph-as-callable. Returns a JSON object with two keys: outputs (the projected output channels) and private_state (the full child snapshot, included when callers want to inspect child-only channels).

Fields

workflow_id: WorkflowId

run_id: RunId

dag: Dag<Arc<dyn StatefulStep>>

schema: Arc<StateSchema>

checkpointer: Arc<dyn Checkpointer>

input_channels: Vec<String>

output_channels: Vec<String>

Trait Implementations

impl Callable for Subgraph

fn call<'life0, 'async_trait>( &'life0 self, input: Value, _ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn label(&self) -> &str

Human-readable label for telemetry. Default falls back to the type name.