Struct CallbackSignature 

pub struct CallbackSignature {
    pub task: String,
    pub task_id: Option<Uuid>,
    pub args: Vec<Value>,
    pub kwargs: HashMap<String, Value>,
    pub options: HashMap<String, Value>,
    pub immutable: bool,
    pub subtask_type: Option<String>,
}

Callback signature for link/errback

Fields

task: String

Task name

task_id: Option<Uuid>

Task ID (optional, will be generated if not provided)

args: Vec<Value>

Positional arguments

kwargs: HashMap<String, Value>

Keyword arguments

options: HashMap<String, Value>

Task options

immutable: bool

Immutable flag (don’t append parent result)

subtask_type: Option<String>

Subtask type (for internal use)

Implementations

impl CallbackSignature

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

Create a new callback signature

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

Set task ID

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

Set positional arguments

pub fn with_kwarg(self, key: impl Into<String>, value: Value) -> Self

Add a keyword argument

pub fn immutable(self) -> Self

Set as immutable

pub fn with_option(self, key: impl Into<String>, value: Value) -> Self

Add an option

Trait Implementations

impl Clone for CallbackSignature

fn clone(&self) -> CallbackSignature

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CallbackSignature

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CallbackSignature

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CallbackSignature

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

where __S: Serializer,

Serialize this value into the given Serde serializer.