Struct RunInput 

#[non_exhaustive]
pub struct RunInput {

    pub persistence: Arc<dyn WorkflowPersistence>,
    pub workflow_run_id: String,
    pub workflow_name: String,
    pub action_registry: Arc<ActionRegistry>,
    pub item_provider_registry: Arc<ItemProviderRegistry>,
    pub script_env_provider: Arc<dyn ScriptEnvProvider>,
    pub run_ctx: Arc<dyn RunContext>,
    pub extra_plugin_dirs: Vec<String>,
    pub model: Option<String>,
    pub exec_config: WorkflowExecConfig,
    pub inputs: HashMap<String, String>,
    pub parent_run_id: String,
    pub depth: u32,
    pub target_label: Option<String>,
    pub default_as_identity: Option<String>,
    pub triggered_by_hook: bool,
    pub schema_resolver: Option<Arc<dyn Fn(&str) -> Result<OutputSchema> + Send + Sync>>,
    pub child_runner: Option<Arc<dyn ChildWorkflowRunner>>,
    pub cancellation: CancellationToken,
    pub event_sinks: Vec<Arc<dyn EventSink>>,
}

All inputs required to start a top-level workflow execution via FlowEngine::run_workflow.

When adding new fields to crate::engine::ExecutionState, add the corresponding slot here so production callers can supply them without reaching into test_helpers.

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.

persistence: Arc<dyn WorkflowPersistence>

workflow_run_id: String

workflow_name: String

action_registry: Arc<ActionRegistry>

item_provider_registry: Arc<ItemProviderRegistry>

script_env_provider: Arc<dyn ScriptEnvProvider>

run_ctx: Arc<dyn RunContext>

extra_plugin_dirs: Vec<String>

model: Option<String>

exec_config: WorkflowExecConfig

inputs: HashMap<String, String>

parent_run_id: String

Empty string for top-level runs.

depth: u32

target_label: Option<String>

default_as_identity: Option<String>

triggered_by_hook: bool

schema_resolver: Option<Arc<dyn Fn(&str) -> Result<OutputSchema> + Send + Sync>>

child_runner: Option<Arc<dyn ChildWorkflowRunner>>

cancellation: CancellationToken

event_sinks: Vec<Arc<dyn EventSink>>

Per-run sinks appended after the engine’s own event sinks.

Implementations

impl RunInput

pub fn new( persistence: Arc<dyn WorkflowPersistence>, workflow_run_id: String, workflow_name: String, action_registry: Arc<ActionRegistry>, item_provider_registry: Arc<ItemProviderRegistry>, script_env_provider: Arc<dyn ScriptEnvProvider>, run_ctx: Arc<dyn RunContext>, cancellation: CancellationToken, ) -> Self

Construct a RunInput with required fields; all optional/defaultable fields are zeroed.

Use direct field assignment (input.model = Some(...)) to set any optional fields.