Struct WorkTask 

pub struct WorkTask {
    pub id: String,
    pub pipeline_id: String,
    pub node_name: String,
    pub input: Value,
    pub wave: u32,
    pub attempt: u32,
    pub idempotency_key: String,
}

A single unit of work: one pipeline node that needs to be executed.

Tasks are serialisable so they can be transmitted to remote workers via Redis Streams, Kafka, HTTP, or any other transport.

Example

use stygian_graph::ports::work_queue::WorkTask;
use serde_json::json;

let task = WorkTask {
    id: "01HX...".to_string(),
    pipeline_id: "pipeline-abc".to_string(),
    node_name: "fetch-homepage".to_string(),
    input: json!({"url": "https://example.com"}),
    wave: 0,
    attempt: 0,
    idempotency_key: "ik-01HX".to_string(),
};
assert_eq!(task.node_name, "fetch-homepage");

Fields

id: String

Unique task identifier (ULID recommended)

pipeline_id: String

Pipeline this task belongs to

node_name: String

Name of the DAG node to execute

input: Value

Input data for the node’s service (serialised as JSON)

wave: u32

Execution wave (tasks in the same wave are independent and can run in parallel)

attempt: u32

Retry attempt number (0 = first attempt)

idempotency_key: String

Idempotency key for safe retries

Trait Implementations

impl Clone for WorkTask

fn clone(&self) -> WorkTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkTask

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkTask

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

where __S: Serializer,

Serialize this value into the given Serde serializer.