Skip to content

feat(sdk): add user-friendly error for non-durable functions #424

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
nvasiu merged 1 commit into from
Jun 4, 2026
Merged

feat(sdk): add user-friendly error for non-durable functions #424

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions sdk/src/main/java/software/amazon/lambda/durable/DurableHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -130,6 +130,11 @@ public final void handleRequest(InputStream inputStream, OutputStream outputStre
var inputString = new String(inputStream.readAllBytes());
logger.debug("Raw input from durable handler: {}", inputString);
var input = serDes.deserialize(inputString, TypeToken.get(DurableExecutionInput.class));
// Durable function inputs must contain DurableExecutionArn and CheckpointToken
if (input.durableExecutionArn() == null || input.checkpointToken() == null) {
throw new IllegalStateException(
"Unexpected payload provided to start the durable execution. DurableConfig must be set in Lambda function configuration.");
}
var output = DurableExecutor.execute(input, context, inputType, this::handleRequest, config);
outputStream.write(serDes.serialize(output).getBytes());
}
Expand Down
18 changes: 18 additions & 0 deletions sdk/src/test/java/software/amazon/lambda/durable/DurableHandlerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,12 @@

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.nio.charset.StandardCharsets;
import org.junit.jupiter.api.Test;

class DurableHandlerTest {
Expand Down Expand Up @@ -47,6 +52,19 @@ public Object handleRequest(Object input, DurableContext context) {
}
}

@Test
void testNonDurableFunctionThrowsUserFriendlyError() throws Exception {
var handler = new TestDurableHandler();
// Durable function inputs must contain DurableExecutionArn and CheckpointToken
var nonDurableInput = "{\"input\": \"non-durable\"}";
var inputStream = new ByteArrayInputStream(nonDurableInput.getBytes(StandardCharsets.UTF_8));
var outputStream = new ByteArrayOutputStream();

var exception =
assertThrows(IllegalStateException.class, () -> handler.handleRequest(inputStream, outputStream, null));
assertTrue(exception.getMessage().contains("Unexpected payload provided to start the durable execution"));
}

// Test handler implementation
private static class TestDurableHandler extends DurableHandler<String, String> {
@Override
Expand Down