Struct Task 

pub struct Task {
    pub task_id: String,
    pub status: TaskStatus,
    pub status_message: Option<String>,
    pub created_at: String,
    pub last_updated_at: String,
    pub ttl: Option<u64>,
    pub poll_interval: Option<u64>,
}

Core task type representing a long-running operation

Fields

• task_id: Unique identifier (MUST be cryptographically secure)
• status: Current task state
• status_message: Optional human-readable status (any state)
• created_at: ISO 8601 timestamp of creation
• last_updated_at: ISO 8601 timestamp when task was last updated
• ttl: Time-to-live in milliseconds from creation (null = unlimited)
• poll_interval: Suggested polling interval in milliseconds

TTL Behavior

TTL is measured from created_at, not from last update:

Creation: 10:00:00, TTL: 60000ms (60s)
Expiry:   10:01:00 (regardless of updates)

After TTL expiry, the receiver MAY delete the task and its results.

Examples

use turbomcp_protocol::types::tasks::{Task, TaskStatus};

let task = Task {
    task_id: "task-123".to_string(),
    status: TaskStatus::Working,
    status_message: Some("Processing data...".to_string()),
    created_at: "2025-11-25T10:30:00Z".to_string(),
    last_updated_at: "2025-11-25T10:30:00Z".to_string(),
    ttl: Some(300_000), // 5 minutes
    poll_interval: Some(5_000), // Poll every 5s
};

assert!(!task.status.is_terminal());
assert_eq!(task.ttl, Some(300_000));

Fields

task_id: String

Unique identifier for this task

MUST be generated by receiver with cryptographic entropy (e.g., UUID v4). Task IDs are the primary access control mechanism.

status: TaskStatus

Current task status

status_message: Option<String>

Optional human-readable status message

Usage by status:

• Cancelled: Reason for cancellation
• Completed: Summary of results
• Failed: Diagnostic info, error details
• Working/InputRequired: Progress updates

created_at: String

ISO 8601 timestamp when task was created

Format: YYYY-MM-DDTHH:MM:SSZ (UTC) TTL is measured from this timestamp.

last_updated_at: String

ISO 8601 timestamp when task was last updated

Format: YYYY-MM-DDTHH:MM:SSZ (UTC) Updated whenever task status or other fields change.

ttl: Option<u64>

Time-to-live in milliseconds from creation

• Some(ms): Task expires after this duration from created_at
• None: Unlimited retention (use with caution)

After expiry, receiver MAY delete task and results. Shorter TTLs improve security by reducing task ID exposure.

poll_interval: Option<u64>

Suggested polling interval in milliseconds

Requestors SHOULD respect this value to avoid excessive polling. Receivers MAY adjust based on task complexity and load.

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Task

fn eq(&self, other: &Task) -> 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 Task

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Task

impl StructuralPartialEq for Task