[feat]: support FLAT nesting type for map/parallel

Author: zhongkechen

sdk/src/main/java/software/amazon/lambda/durable/context/DurableContextImpl.java

@@ -37,14 +37,12 @@
 import software.amazon.lambda.durable.model.WaitForConditionResult;
 import software.amazon.lambda.durable.operation.CallbackOperation;
 import software.amazon.lambda.durable.operation.ChildContextOperation;
-import software.amazon.lambda.durable.operation.ConcurrencyOperation;
 import software.amazon.lambda.durable.operation.InvokeOperation;
 import software.amazon.lambda.durable.operation.MapOperation;
 import software.amazon.lambda.durable.operation.ParallelOperation;
 import software.amazon.lambda.durable.operation.StepOperation;
 import software.amazon.lambda.durable.operation.WaitForConditionOperation;
 import software.amazon.lambda.durable.operation.WaitOperation;
-import software.amazon.lambda.durable.serde.SerDes;
 import software.amazon.lambda.durable.util.ParameterValidator;
 
 /**

sdk/src/main/java/software/amazon/lambda/durable/operation/ChildContextOperation.java

@@ -8,7 +8,6 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Function;
-
 import software.amazon.awssdk.services.lambda.model.ContextDetails;
 import software.amazon.awssdk.services.lambda.model.ContextOptions;
 import software.amazon.awssdk.services.lambda.model.ErrorObject;
@@ -242,8 +241,7 @@ private Throwable translateException(Operation op, ErrorObject errorObject) {
             case RUN_IN_CHILD_CONTEXT -> new ChildContextFailedException(op);
 
             // the following subtypes should not be able to reach here
-            case PARALLEL, MAP, WAIT_FOR_CONDITION ->
-                    new IllegalStateException("Unexpected sub-type: " + getSubType());
+            case PARALLEL, MAP, WAIT_FOR_CONDITION -> new IllegalStateException("Unexpected sub-type: " + getSubType());
         };
     }
 

sdk/src/test/java/software/amazon/lambda/durable/operation/ConcurrencyOperationTest.java

@@ -64,7 +64,8 @@ void setUp() {
                 .thenReturn(DurableConfig.builder()
                         .withExecutorService(Executors.newCachedThreadPool())
                         .build());
-        when(durableContext.createChildContext(anyString(), anyString(), anyBoolean())).thenReturn(childContext);
+        when(durableContext.createChildContext(anyString(), anyString(), anyBoolean()))
+                .thenReturn(childContext);
         when(executionManager.getCurrentThreadContext()).thenReturn(new ThreadContext("Root", ThreadType.CONTEXT));
         // All child operations are NOT in replay
         when(executionManager.getOperationAndUpdateReplayState(anyString())).thenReturn(null);