Struct WorkflowExecutor

pub struct WorkflowExecutor {
    storage: Arc<Storage>,
    scheduler: Arc<Scheduler>,
    num_workers: usize,
    registry: Arc<NodeRegistry>,
    running: Arc<Mutex<bool>>,
    python_manager: Arc<Mutex<Option<Arc<PythonManager>>>>,
}

Fields

storage: Arc<Storage>

scheduler: Arc<Scheduler>

num_workers: usize

registry: Arc<NodeRegistry>

running: Arc<Mutex<bool>>

python_manager: Arc<Mutex<Option<Arc<PythonManager>>>>

Implementations

impl WorkflowExecutor

pub fn new( storage: Arc<Storage>, num_workers: usize, registry: Arc<NodeRegistry>, ) -> Self

Create an asynchronous executor with storage and workers

pub async fn set_python_manager(&self, manager: Arc<PythonManager>)

Set the Python manager for script execution

pub async fn get_python_manager(&self) -> Option<Arc<PythonManager>>

Get the Python manager if available

pub async fn submit(&self, workflow_id: String, input: Value) -> Result<String>

pub async fn submit_with_execution_id( &self, workflow_id: String, input: Value, execution_id: String, ) -> Result<String>

pub async fn submit_node(&self, node: Node, input: Value) -> Result<String>

Submit a single node for execution

pub async fn start(&self)

async fn submit_async( &self, workflow_id: String, input: Value, ) -> Result<String>

async fn submit_async_with_id( &self, workflow_id: String, input: Value, execution_id: String, ) -> Result<String>

async fn try_start(&self) -> bool

fn recover_stalled_tasks(&self)

async fn spawn_workers(&self, num_workers: usize)

async fn execute_node( node: &Node, input: &NodeInput, context: &mut ExecutionContext, registry: Arc<NodeRegistry>, ) -> Result<NodeOutput>

Resolves Templated fields in NodeInput using execution context, then delegates to node-specific executor for actual execution.

pub async fn get_task_status(&self, task_id: &str) -> Result<Task>

pub async fn get_execution_status( &self, execution_id: &str, ) -> Result<Vec<Task>>

pub async fn list_tasks( &self, workflow_id: Option<&str>, status: Option<TaskStatus>, ) -> Result<Vec<Task>>