Skip to main content

ChildWorkflowRunner

Trait ChildWorkflowRunner 

Source
pub trait ChildWorkflowRunner: Send + Sync {
    // Required methods
    fn execute_child(
        &self,
        workflow_name: &str,
        parent_ctx: &ChildWorkflowContext,
        params: ChildWorkflowInput,
    ) -> Result<WorkflowResult>;
    fn resume_child(
        &self,
        workflow_run_id: &str,
        model: Option<&str>,
        parent_ctx: &ChildWorkflowContext,
    ) -> Result<WorkflowResult>;
    fn find_resumable_child(
        &self,
        parent_run_id: &str,
        workflow_name: &str,
    ) -> Result<Option<WorkflowRun>>;
}
Expand description

Trait for executing child workflows — allows conductor-core to inject its adapter.

Required Methods§

Source

fn execute_child( &self, workflow_name: &str, parent_ctx: &ChildWorkflowContext, params: ChildWorkflowInput, ) -> Result<WorkflowResult>

Source

fn resume_child( &self, workflow_run_id: &str, model: Option<&str>, parent_ctx: &ChildWorkflowContext, ) -> Result<WorkflowResult>

Source

fn find_resumable_child( &self, parent_run_id: &str, workflow_name: &str, ) -> Result<Option<WorkflowRun>>

Implementors§