Struct WorkflowTask 

pub struct WorkflowTask {
    pub id: Uuid,
    pub task_name: String,
    pub args: Vec<Value>,
    pub kwargs: HashMap<String, Value>,
    pub dependencies: Vec<Uuid>,
}

A task in a workflow

Fields

id: Uuid

Unique task identifier

task_name: String

Task name

args: Vec<Value>

Task arguments (JSON)

kwargs: HashMap<String, Value>

Task keyword arguments (JSON)

dependencies: Vec<Uuid>

Dependencies (task IDs that must complete first)

Implementations

impl WorkflowTask

pub fn new(task_name: impl Into<String>) -> Self

Create a new workflow task

pub fn with_args(self, args: Vec<Value>) -> Self

Set task arguments

pub fn with_kwargs(self, kwargs: HashMap<String, Value>) -> Self

Set task keyword arguments

pub fn depends_on(self, task_id: Uuid) -> Self

Add a dependency on another task

pub fn depends_on_many(self, task_ids: Vec<Uuid>) -> Self

Add multiple dependencies

pub fn to_message( &self, root_id: Option<Uuid>, parent_id: Option<Uuid>, ) -> Message

Convert to a Message with workflow metadata

Trait Implementations

impl Clone for WorkflowTask

fn clone(&self) -> WorkflowTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowTask

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowTask

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.