Skip to content

Commit 1de6db3

Browse files
committed
add result
1 parent 6e32656 commit 1de6db3

2 files changed

Lines changed: 11 additions & 7 deletions

File tree

sdk-integration-tests/src/test/java/software/amazon/lambda/durable/ParallelIntegrationTest.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -602,12 +602,11 @@ void testParallelWithMinSuccessful_earlyTermination() {
602602
assertEquals(
603603
ExecutionStatus.SUCCEEDED,
604604
result.getStatus(),
605-
"Failed with error: "
606-
+ String.join(
607-
" ",
608-
result.getOperations().stream()
609-
.map(TestOperation::toString)
610-
.toList()));
605+
String.join(
606+
" ",
607+
result.getOperations().stream()
608+
.map(TestOperation::toString)
609+
.toList()));
611610
}
612611

613612
@Test

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,12 @@ private BaseDurableOperation waitForChildCompletion(
260260
executionManager.deregisterActiveThread(threadContext.threadId());
261261
}
262262
}
263-
return future.thenApply(o -> (BaseDurableOperation) o).join();
263+
try {
264+
return future.thenApply(o -> (BaseDurableOperation) o).join();
265+
} catch (Throwable throwable) {
266+
ExceptionHelper.sneakyThrow(ExceptionHelper.unwrapCompletableFuture(throwable));
267+
throw throwable;
268+
}
264269
}
265270

266271
/**

0 commit comments

Comments
 (0)