Struct TaskFrame 

pub struct TaskFrame {
    pub task_id: String,
    pub dag: Value,
    pub timeout_ms: Option<u64>,
    pub callback_url: Option<String>,
    pub context: Option<Value>,
    pub priority: Option<String>,
    pub depth: Option<i64>,
    pub compensation_policy: Option<String>,
    pub result_ttl_seconds: u64,
}

Fields

task_id: String

dag: Value

timeout_ms: Option<u64>

callback_url: Option<String>

context: Option<Value>

priority: Option<String>

depth: Option<i64>

compensation_policy: Option<String>

result_ttl_seconds: u64

NOP v0.7 — how long the result is cached; default 3600 s.

Implementations

impl TaskFrame

pub fn frame_type() -> FrameType

pub fn to_dict(&self) -> FrameDict

pub fn from_dict(d: &FrameDict) -> NpsResult<Self>

Trait Implementations

impl Clone for TaskFrame

fn clone(&self) -> TaskFrame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskFrame

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

Formats the value using the given formatter.