Skip to main content

AWS Durable Execution SDK for Python

Project description

AWS Durable Execution SDK for Python

Build PyPI - Version PyPI - Python Version OpenSSF Scorecard License


Build reliable, long-running AWS Lambda workflows with checkpointed steps, waits, callbacks, and parallel execution.

✨ Key Features

  • Automatic checkpointing - Resume execution after Lambda pauses or restarts
  • Durable steps - Run work with retry strategies and deterministic replay
  • Waits and callbacks - Pause for time or external signals without blocking Lambda
  • Parallel and map operations - Fan out work with configurable completion criteria
  • Child contexts - Structure complex workflows into isolated subflows
  • Replay-safe logging - Use context.logger for structured, de-duplicated logs
  • Local and cloud testing - Validate workflows with the testing SDK

📦 Packages

Package Description Version
aws-durable-execution-sdk-python Execution SDK for Lambda durable functions PyPI - Version
aws-durable-execution-sdk-python-testing Local/cloud test runner and pytest helpers PyPI - Version

🚀 Quick Start

Install the execution SDK:

pip install aws-durable-execution-sdk-python

Create a durable Lambda handler:

from aws_durable_execution_sdk_python import (
    DurableContext,
    StepContext,
    durable_execution,
    durable_step,
)
from aws_durable_execution_sdk_python.config import Duration

@durable_step
def validate_order(step_ctx: StepContext, order_id: str) -> dict:
    step_ctx.logger.info("Validating order", extra={"order_id": order_id})
    return {"order_id": order_id, "valid": True}

@durable_execution
def handler(event: dict, context: DurableContext) -> dict:
    order_id = event["order_id"]
    context.logger.info("Starting workflow", extra={"order_id": order_id})

    validation = context.step(validate_order(order_id), name="validate_order")
    if not validation["valid"]:
        return {"status": "rejected", "order_id": order_id}

    # simulate approval (real world: use wait_for_callback)
    context.wait(duration=Duration.from_seconds(5), name="await_confirmation")

    return {"status": "approved", "order_id": order_id}

📚 Documentation

The complete documentation for the AWS Durable Execution SDK for Python lives on the AWS Documentation site:

💬 Feedback & Support

📄 License

See the LICENSE file for our project's licensing.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

aws_durable_execution_sdk_python-1.7.0.tar.gz (240.8 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

File details

Details for the file aws_durable_execution_sdk_python-1.7.0.tar.gz.

File metadata

File hashes

Hashes for aws_durable_execution_sdk_python-1.7.0.tar.gz
Algorithm Hash digest
SHA256 6ce773cfba243df98ec35f375a30b98cc4779a9f921d8c6d1180773811bf57f0
MD5 f6b0e7634f3c2010b903749645c7b297
BLAKE2b-256 e4019dbd9e012267b8e18e64943fcad707a626e4f13b0d948fd5b02e7126962b

See more details on using hashes here.

Provenance

The following attestation bundles were made for aws_durable_execution_sdk_python-1.7.0.tar.gz:

Publisher: pypi-publish.yml on aws/aws-durable-execution-sdk-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file aws_durable_execution_sdk_python-1.7.0-py3-none-any.whl.

File metadata

File hashes

Hashes for aws_durable_execution_sdk_python-1.7.0-py3-none-any.whl
Algorithm Hash digest
SHA256 1482e1f439e36deb1fcf9a086499b3788c3facf3ac755e50376a739081cc72a0
MD5 184aafb27514fa4b869a29f5bca63bee
BLAKE2b-256 98210cba2b6a42d3d60b266e4fdc7e4d85035838f0a893dadf725252765556f6

See more details on using hashes here.

Provenance

The following attestation bundles were made for aws_durable_execution_sdk_python-1.7.0-py3-none-any.whl:

Publisher: pypi-publish.yml on aws/aws-durable-execution-sdk-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page