Struct OperationUpdate 

pub struct OperationUpdate {

    pub operation_id: String,
    pub action: OperationAction,
    pub operation_type: OperationType,
    pub result: Option<String>,
    pub error: Option<ErrorObject>,
    pub parent_id: Option<String>,
    pub name: Option<String>,
    pub sub_type: Option<String>,
    pub wait_options: Option<WaitOptions>,
    pub step_options: Option<StepOptions>,
    pub callback_options: Option<CallbackOptions>,
    pub chained_invoke_options: Option<ChainedInvokeOptions>,
    pub context_options: Option<ContextOptions>,
}

Represents an update to be checkpointed for an operation.

This struct is used to send checkpoint requests to the Lambda service. Field names match the CheckpointDurableExecution API format.

Fields

operation_id: String

Unique identifier for this operation

action: OperationAction

The action to perform (Start, Succeed, Fail)

operation_type: OperationType

The type of operation

result: Option<String>

Serialized result if succeeding (called “Payload” in the API)

error: Option<ErrorObject>

Error details if failing

parent_id: Option<String>

Parent operation ID for nested operations

name: Option<String>

Optional human-readable name for the operation

sub_type: Option<String>

SDK-level categorization of the operation (e.g., “map”, “parallel”, “wait_for_condition”) Requirements: 23.3, 23.4

wait_options: Option<WaitOptions>

Options for WAIT operations

step_options: Option<StepOptions>

Options for STEP operations

callback_options: Option<CallbackOptions>

Options for CALLBACK operations

chained_invoke_options: Option<ChainedInvokeOptions>

Options for CHAINED_INVOKE operations

context_options: Option<ContextOptions>

Options for CONTEXT operations

Implementations

impl OperationUpdate

pub fn start( operation_id: impl Into<String>, operation_type: OperationType, ) -> OperationUpdate

Creates a new OperationUpdate to start an operation.

pub fn start_wait( operation_id: impl Into<String>, wait_seconds: u64, ) -> OperationUpdate

Creates a new OperationUpdate to start a WAIT operation with the required WaitOptions.

pub fn succeed( operation_id: impl Into<String>, operation_type: OperationType, result: Option<String>, ) -> OperationUpdate

Creates a new OperationUpdate to mark an operation as succeeded.

pub fn fail( operation_id: impl Into<String>, operation_type: OperationType, error: ErrorObject, ) -> OperationUpdate

Creates a new OperationUpdate to mark an operation as failed.

pub fn cancel( operation_id: impl Into<String>, operation_type: OperationType, ) -> OperationUpdate

Creates a new OperationUpdate to cancel an operation.

This is primarily used for cancelling WAIT operations.

Arguments

• operation_id - The ID of the operation to cancel
• operation_type - The type of operation being cancelled

pub fn retry( operation_id: impl Into<String>, operation_type: OperationType, payload: Option<String>, next_attempt_delay_seconds: Option<u64>, ) -> OperationUpdate

Creates a new OperationUpdate to retry an operation with optional payload.

This is used for the wait-for-condition pattern where state needs to be passed between retry attempts. The payload contains the state to preserve across retries, not an error.

Arguments

• operation_id - The ID of the operation to retry
• operation_type - The type of operation being retried
• payload - Optional state payload to preserve across retries
• next_attempt_delay_seconds - Optional delay before the next retry attempt

pub fn retry_with_error( operation_id: impl Into<String>, operation_type: OperationType, error: ErrorObject, next_attempt_delay_seconds: Option<u64>, ) -> OperationUpdate

Creates a new OperationUpdate to retry an operation with an error.

This is used for traditional retry scenarios where the operation failed and needs to be retried after a delay.

Arguments

• operation_id - The ID of the operation to retry
• operation_type - The type of operation being retried
• error - The error that caused the retry
• next_attempt_delay_seconds - Optional delay before the next retry attempt

pub fn with_parent_id(self, parent_id: impl Into<String>) -> OperationUpdate

Sets the parent ID for this operation update.

pub fn with_name(self, name: impl Into<String>) -> OperationUpdate

Sets the name for this operation update.

pub fn with_sub_type(self, sub_type: impl Into<String>) -> OperationUpdate

Sets the sub-type for this operation update. Requirements: 23.3, 23.4

pub fn with_wait_options(self, wait_seconds: u64) -> OperationUpdate

Sets the wait options for this operation update.

pub fn with_step_options( self, next_attempt_delay_seconds: Option<u64>, ) -> OperationUpdate

Sets the step options for this operation update.

pub fn with_callback_options( self, timeout_seconds: Option<u64>, heartbeat_timeout_seconds: Option<u64>, ) -> OperationUpdate

Sets the callback options for this operation update.

pub fn with_chained_invoke_options( self, function_name: impl Into<String>, tenant_id: Option<String>, ) -> OperationUpdate

Sets the chained invoke options for this operation update.

pub fn with_context_options( self, replay_children: Option<bool>, ) -> OperationUpdate

Sets the context options for this operation update.

Trait Implementations

impl Clone for OperationUpdate

fn clone(&self) -> OperationUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperationUpdate

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperationUpdate

fn deserialize<__D>( __deserializer: __D, ) -> Result<OperationUpdate, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OperationUpdate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.