pub struct WorkflowEngine { /* private fields */ }Implementations§
Source§impl WorkflowEngine
impl WorkflowEngine
pub fn new( engine: Arc<InferenceEngine>, scheduler: Arc<InferenceScheduler>, storage: Arc<dyn WorkflowStorage>, skills_path: PathBuf, ) -> Self
pub fn storage(&self) -> Arc<dyn WorkflowStorage>
pub async fn run<F>(
&self,
skill_name: &str,
session_id: &str,
context: Value,
resume_from_step: Option<String>,
force_regenerate: Vec<String>,
on_progress: Option<F>,
) -> Result<HashMap<String, String>>where
F: FnMut(PipelineEvent),
Auto Trait Implementations§
impl Freeze for WorkflowEngine
impl !RefUnwindSafe for WorkflowEngine
impl Send for WorkflowEngine
impl Sync for WorkflowEngine
impl Unpin for WorkflowEngine
impl UnsafeUnpin for WorkflowEngine
impl !UnwindSafe for WorkflowEngine
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more