Struct Operation 

pub struct Operation {

    pub operation_id: String,
    pub operation_type: OperationType,
    pub status: OperationStatus,
    pub result: Option<String>,
    pub error: Option<ErrorObject>,
    pub parent_id: Option<String>,
    pub name: Option<String>,
    pub sub_type: Option<String>,
    pub start_timestamp: Option<i64>,
    pub end_timestamp: Option<i64>,
    pub execution_details: Option<ExecutionDetails>,
    pub step_details: Option<StepDetails>,
    pub wait_details: Option<WaitDetails>,
    pub callback_details: Option<CallbackDetails>,
    pub chained_invoke_details: Option<ChainedInvokeDetails>,
    pub context_details: Option<ContextDetails>,
}

Represents a checkpointed operation in a durable execution.

Operations are the fundamental unit of state in durable executions. Each operation has a unique ID and tracks its type, status, and result.

Examples

Creating a new operation:

use durable_execution_sdk::operation::{Operation, OperationType, OperationStatus};

let op = Operation::new("step-001", OperationType::Step);
assert_eq!(op.operation_id, "step-001");
assert_eq!(op.operation_type, OperationType::Step);
assert_eq!(op.status, OperationStatus::Started);

Serializing and deserializing operations:

use durable_execution_sdk::operation::{Operation, OperationType, OperationStatus};

let mut op = Operation::new("wait-001", OperationType::Wait);
op.status = OperationStatus::Succeeded;
op.result = Some("done".to_string());

let json = serde_json::to_string(&op).unwrap();
let restored: Operation = serde_json::from_str(&json).unwrap();

assert_eq!(restored.operation_id, "wait-001");
assert_eq!(restored.status, OperationStatus::Succeeded);

Fields

operation_id: String

Unique identifier for this operation

operation_type: OperationType

The type of operation (Step, Wait, Callback, etc.)

status: OperationStatus

Current status of the operation

result: Option<String>

Serialized result if the operation succeeded (legacy field, prefer type-specific details)

error: Option<ErrorObject>

Error details if the operation failed

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

start_timestamp: Option<i64>

Start timestamp of the operation (milliseconds since epoch)

end_timestamp: Option<i64>

End timestamp of the operation (milliseconds since epoch)

execution_details: Option<ExecutionDetails>

Execution details for EXECUTION type operations

step_details: Option<StepDetails>

Step details for STEP type operations

wait_details: Option<WaitDetails>

Wait details for WAIT type operations

callback_details: Option<CallbackDetails>

Callback details for CALLBACK type operations

chained_invoke_details: Option<ChainedInvokeDetails>

Chained invoke details for CHAINED_INVOKE type operations

context_details: Option<ContextDetails>

Context details for CONTEXT type operations

Implementations

impl Operation

pub fn new( operation_id: impl Into<String>, operation_type: OperationType, ) -> Operation

Creates a new Operation with the given ID and type.

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

Sets the parent ID for this operation.

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

Sets the name for this operation.

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

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

pub fn is_completed(&self) -> bool

Returns true if the operation has completed (succeeded or failed).

pub fn is_succeeded(&self) -> bool

Returns true if the operation succeeded.

pub fn is_failed(&self) -> bool

Returns true if the operation failed.

pub fn get_result(&self) -> Option<&str>

Gets the result from the appropriate details field based on operation type.

pub fn get_retry_payload(&self) -> Option<&str>

Gets the retry payload from StepDetails for STEP operations.

This is used for the wait-for-condition pattern where state is passed between retry attempts via the Payload field.

Returns

The payload string if this is a STEP operation with a payload, None otherwise.

pub fn get_attempt(&self) -> Option<u32>

Gets the current attempt number from StepDetails for STEP operations.

Returns

The attempt number (0-indexed) if this is a STEP operation with attempt tracking, None otherwise.

Trait Implementations

impl Clone for Operation

fn clone(&self) -> Operation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Operation

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Operation

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Operation

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.