stasis-rs 0.7.0

Durable AI orchestration framework with runtime jobs, lineage, and memory integration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use async_trait::async_trait;
use serde_json::Value;

use crate::domain::errors::Result;

#[derive(Clone, Debug)]
pub struct WorkflowExecutionOutput {
    pub run_id: String,
    pub execution: Value,
    pub final_state: Value,
    pub lint_warnings: Value,
}

#[async_trait]
pub trait WorkflowEngine: Send + Sync {
    async fn execute_grapheme_source(
        &self,
        source: &str,
        state_current: Option<&Value>,
    ) -> Result<WorkflowExecutionOutput>;
}