AWS Durable Execution SDKs for JavaScript

---

Build resilient, long-running AWS Lambda functions with automatic state persistence, retry logic, and workflow orchestration. Lambda durable functions can run for up to one year while maintaining reliable progress through checkpoints and automatic failure recovery.

✨ Key Features

• Durable Execution – Automatically persists state and resumes from checkpoints after failures
• Automatic Retries – Configurable retry strategies with exponential backoff and jitter
• Workflow Orchestration – Compose complex workflows with steps, child contexts, and parallel execution
• External Integration – Wait for callbacks from external systems (human-in-the-loop, webhooks)
• Batch Operations – Process arrays with concurrency control and completion policies
• Cost Efficient – Pay only for active compute time; waits suspend without charges
• Type Safety – Full TypeScript support with comprehensive type definitions

📦 Packages

This monorepo contains the following NPM packages:

Package	Description	NPM
@aws/durable-execution-sdk-js	Core SDK for building durable Lambda functions
@aws/durable-execution-sdk-js-testing	Testing utilities for local development and CI/CD
@aws/durable-execution-sdk-js-eslint-plugin	ESLint rules for durable function best practices

🚀 Quick Start

Installation

npm install @aws/durable-execution-sdk-js

Your First Durable Function

import {
  withDurableExecution,
  DurableContext,
} from "@aws/durable-execution-sdk-js";

const handler = async (event: any, context: DurableContext) => {
  // Use the context logger for structured logging
  context.logger.info("Starting workflow", { userId: event.userId });

  // Execute a durable step with automatic retry
  const userData = await context.step("fetch-user", async (stepCtx) => {
    // Step-scoped logger includes step metadata
    stepCtx.logger.debug("Fetching user from database");
    return fetchUserFromDB(event.userId);
  });

  // Wait for 5 seconds (no compute charges during wait)
  await context.wait({ seconds: 5 });

  // Process data in another step
  const result = await context.step("process-user", async (stepCtx) => {
    return processUser(userData);
  });

  context.logger.info("Workflow completed", { result });
  return result;
};

export const lambdaHandler = withDurableExecution(handler);

📚 Documentation

• AWS Documentation – Official AWS Lambda durable functions guide
• SDK README – Detailed SDK usage guide with code examples
• API Reference – Complete technical reference with type definitions
• Concepts & Use Cases – Replay model, best practices, and real-world patterns
• Examples – Working examples including hello-world, callbacks, parallel processing, and more

🧪 Testing

The testing SDK enables local development and unit testing without deploying to AWS, as well as cloud testing against deployed Lambda functions:

npm install @aws/durable-execution-sdk-js-testing --save-dev

import { LocalDurableTestRunner } from "@aws/durable-execution-sdk-js-testing";

// Create runner with skipTime to fast-forward through waits
const runner = new LocalDurableTestRunner({
  handlerFunction: myDurableHandler,
});
await runner.setupTestEnvironment({ skipTime: true });

const result = await runner.run({ userId: "123" });

// Assert execution status
expect(result.getStatus()).toBe("SUCCEEDED");
expect(result.getResult()).toEqual({ processedUser: "..." });

// Assert number of Lambda invocations (initial+replay after wait)
expect(result.getInvocations().length).toBe(2);

// Assert operations executed
const operations = result.getOperations();
expect(operations.length).toBe(3); // 2 steps + 1 wait

// Inspect individual operations
const fetchStep = runner.getOperation("fetch-user");
expect(fetchStep.getStatus()).toBe("SUCCEEDED");

See the Testing SDK documentation for more details.

💬 Feedback & Support

• 🐛 Report a Bug – Found something broken? Let us know
• 💡 Request a Feature – Share ideas for improvements
• 📖 Documentation Issue – Report unclear or missing docs
• 💬 Discussions – Ask questions and connect with the community

🤝 Contributing

We welcome contributions! Please see CONTRIBUTING.md for guidelines.

🔒 Security

See CONTRIBUTING for information about reporting security issues.

📄 License

This project is licensed under the Apache-2.0 License. See LICENSE for details.