chore: add deserialization for execution object

Author: bchampp

src/aws_durable_execution_sdk_python_testing/execution.py

@@ -3,20 +3,27 @@
 import json
 from dataclasses import replace
 from datetime import UTC, datetime
-from typing import TYPE_CHECKING
+from typing import TYPE_CHECKING, Any
 from uuid import uuid4
 
 from aws_durable_execution_sdk_python.execution import (
     DurableExecutionInvocationOutput,
     InvocationStatus,
 )
 from aws_durable_execution_sdk_python.lambda_service import (
+    CallbackOptions,
+    ContextOptions,
     ErrorObject,
     ExecutionDetails,
+    InvokeOptions,
     Operation,
+    OperationAction,
     OperationStatus,
+    OperationSubType,
     OperationType,
     OperationUpdate,
+    StepOptions,
+    WaitOptions,
 )
 
 # Import AWS exceptions
@@ -27,6 +34,54 @@
 from aws_durable_execution_sdk_python_testing.token import CheckpointToken
 
 
+def _operation_update_from_dict(data: dict[str, Any]) -> OperationUpdate:
+    """Create OperationUpdate from dictionary data."""
+    error = ErrorObject.from_dict(data["Error"]) if data.get("Error") else None
+
+    context_options = None
+    if context_data := data.get("ContextOptions"):
+        context_options = ContextOptions(
+            replay_children=context_data.get("ReplayChildren", False)
+        )
+
+    step_options = None
+    if step_data := data.get("StepOptions"):
+        step_options = StepOptions(
+            next_attempt_delay_seconds=step_data.get("NextAttemptDelaySeconds")
+        )
+
+    wait_options = None
+    if wait_data := data.get("WaitOptions"):
+        wait_options = WaitOptions.from_dict(wait_data)
+
+    callback_options = None
+    if callback_data := data.get("CallbackOptions"):
+        callback_options = CallbackOptions.from_dict(callback_data)
+
+    invoke_options = None
+    if invoke_data := data.get("InvokeOptions"):
+        invoke_options = InvokeOptions(
+            function_name=invoke_data.get("FunctionName", ""),
+            timeout_seconds=invoke_data.get("TimeoutSeconds"),
+        )
+
+    return OperationUpdate(
+        operation_id=data["Id"],
+        operation_type=OperationType(data["Type"]),
+        action=OperationAction(data["Action"]),
+        parent_id=data.get("ParentId"),
+        name=data.get("Name"),
+        sub_type=OperationSubType(data["SubType"]) if data.get("SubType") else None,
+        payload=data.get("Payload"),
+        error=error,
+        context_options=context_options,
+        step_options=step_options,
+        wait_options=wait_options,
+        callback_options=callback_options,
+        invoke_options=invoke_options,
+    )
+
+
 if TYPE_CHECKING:
     from aws_durable_execution_sdk_python_testing.model import (
         StartDurableExecutionInput,