Package software.amazon.lambda.durable.examples.parallel

Class ParallelFailureToleranceExample

java.lang.Object

software.amazon.lambda.durable.DurableHandler<ParallelFailureToleranceExample.Input,ParallelFailureToleranceExample.Output>

software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

public class ParallelFailureToleranceExample
extends DurableHandler<ParallelFailureToleranceExample.Input,ParallelFailureToleranceExample.Output>

Example demonstrating parallel execution with failure tolerance.

When toleratedFailureCount is set, the parallel operation completes successfully even if some branches fail — as long as the number of failures does not exceed the threshold. Failed branches produce null results that callers can filter out.

Use this pattern when partial success is acceptable, for example: sending notifications to multiple channels where some channels may be unavailable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ParallelFailureToleranceExample.Input
static final record	ParallelFailureToleranceExample.Output

Constructor Summary

Constructors

Constructor	Description
ParallelFailureToleranceExample()

Method Summary

Modifier and Type	Method	Description
ParallelFailureToleranceExample.Output	handleRequest(ParallelFailureToleranceExample.Input input, DurableContext context)	Handle the durable execution.

Methods inherited from class software.amazon.lambda.durable.DurableHandler

createConfiguration, getConfiguration, handleRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ParallelFailureToleranceExample

public ParallelFailureToleranceExample()

Method Details

handleRequest

public ParallelFailureToleranceExample.Output handleRequest(ParallelFailureToleranceExample.Input input,
 DurableContext context)

Description copied from class: DurableHandler

Handle the durable execution.

Specified by:

handleRequest in class DurableHandler<ParallelFailureToleranceExample.Input,ParallelFailureToleranceExample.Output>

Parameters:

input - User input

context - Durable context for operations

Returns:

Result