Skip to content

Commit 1b63036

Browse files
committed
fix examples
1 parent 8bd740b commit 1b63036

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

examples/src/main/java/software/amazon/lambda/durable/examples/parallel/DeserializationFailedParallelExample.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import software.amazon.lambda.durable.config.ParallelBranchConfig;
1111
import software.amazon.lambda.durable.config.ParallelConfig;
1212
import software.amazon.lambda.durable.exception.SerDesException;
13+
import software.amazon.lambda.durable.execution.SuspendExecutionException;
1314
import software.amazon.lambda.durable.serde.JacksonSerDes;
1415

1516
/**
@@ -55,6 +56,8 @@ public String handleRequest(Input input, DurableContext context) {
5556
parallel.get();
5657
try {
5758
return future.get();
59+
} catch (SuspendExecutionException e) {
60+
throw e;
5861
} catch (Exception e) {
5962
return e.getMessage();
6063
}

examples/src/main/java/software/amazon/lambda/durable/examples/step/DeserializationFailureExample.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import software.amazon.lambda.durable.TypeToken;
99
import software.amazon.lambda.durable.config.StepConfig;
1010
import software.amazon.lambda.durable.exception.SerDesException;
11+
import software.amazon.lambda.durable.execution.SuspendExecutionException;
1112
import software.amazon.lambda.durable.serde.JacksonSerDes;
1213

1314
public class DeserializationFailureExample extends DurableHandler<String, String> {
@@ -22,6 +23,8 @@ public String handleRequest(String input, DurableContext context) {
2223
throw new RuntimeException("this is a test");
2324
},
2425
StepConfig.builder().serDes(new FailedSerDes()).build());
26+
} catch (SuspendExecutionException e) {
27+
throw e;
2528
} catch (Exception e) {
2629
context.wait("suspend and replay", Duration.ofSeconds(1));
2730
return e.getClass().getSimpleName() + ":" + e.getMessage();

0 commit comments

Comments
 (0)