Struct Workflow 

pub struct Workflow {
    pub id: String,
    pub name: String,
    pub task_list: TaskList,
    pub agents: HashMap<String, Arc<Agent>>,
    pub event_tracker: Arc<RwLock<EventTracker>>,
    pub global_context: Option<Value>,
}

Rust-specific implementation of a workflow

Fields

id: String

name: String

task_list: TaskList

agents: HashMap<String, Arc<Agent>>

event_tracker: Arc<RwLock<EventTracker>>

global_context: Option<Value>

Implementations

impl Workflow

pub async fn reset_agents(&mut self) -> Result<(), WorkflowError>

Reload the agent clients by overwriting the existing clients We are trying to solve the deserialization issue where GenAIClient requires and async context to be created. During deserialization we don’t have that context, so we default to an Undefined client, but keep the other agent details. This means that if we try to run a workflow after deserialization we will get an error when we try to execute a task with an Undefined client. For this specific function, we can either make Arc into RW compatible, or we can rebuild the entire agents map with new Arcs. Given that the only mutation we need to do is to rebuild the GenAIClient, we opt for the latter because we don’t need to make everything else RW compatible. This will incure a small startup cost, but it will be a one-time cost and 99% of the time unnoticed.

pub fn new(name: &str) -> Self

pub fn events(&self) -> Vec<TaskEvent>

pub fn total_duration(&self) -> i32

pub fn get_new_workflow( &self, global_context: Option<Value>, ) -> Result<Self, WorkflowError>

pub async fn run( &self, global_context: Option<Value>, ) -> Result<Arc<RwLock<Workflow>>, WorkflowError>

pub fn is_complete(&self) -> bool

pub fn pending_count(&self) -> usize

pub fn add_task(&mut self, task: Task) -> Result<(), WorkflowError>

pub fn add_tasks(&mut self, tasks: Vec<Task>) -> Result<(), WorkflowError>

pub fn add_agent(&mut self, agent: &Agent)

pub fn execution_plan( &self, ) -> Result<HashMap<i32, HashSet<String>>, WorkflowError>

pub fn __str__(&self) -> String

pub fn serialize(&self) -> Result<String, Error>

pub fn from_json(json: &str) -> Result<Self, WorkflowError>

pub fn task_names(&self) -> Vec<String>

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Workflow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Workflow

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Workflow

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Workflow

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Workflow

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.