DurableStack for Python

DurableStack provides reliable background jobs and recurring scheduling for Python applications.

Install

pip install durablestack

Quick Start

from datetime import datetime, UTC

from durablestack import create_durable_stack


async def send_email(payload: object) -> None:
    print("sending", payload)


runtime = create_durable_stack()
runtime.register_job("send-email", send_email)

await runtime.start()
run_id = await runtime.enqueue("send-email", {"to": "hello@example.com"})
print("enqueued", run_id)

await runtime.stop()

Providers

• InMemory
• PostgreSQL
• MySQL
• SQL Server
• SQLite

Runtime Features

• Durable lifecycle with lease-based execution
• Retries with configurable backoff behavior
• Recurring schedules with IANA time zones
• Runtime-control command sync and receipt tracking
• Hosted telemetry ingestion support

Optional Hosted Eventing / Runtime-Control

When tenant credentials are configured, the runtime can publish telemetry and receive runtime-control commands.

from durablestack.core.options import DurableStackOptions, EventingOptions
from durablestack import create_durable_stack

runtime = create_durable_stack(
    DurableStackOptions(
        eventing=EventingOptions(
            tenant_id="<tenant-id>",
            client_secret="<client-secret>",
            service_name="my-python-worker",
        ),
        include_error_detail_in_events=True,
    )
)

Project Links

• Homepage: https://durablestack.com
• Documentation: https://docs.durablestack.com
• Source: https://github.com/durablestack/durablestack-python