Django Durable

Durable execution framework for Django web apps.

Workflows are ordinary Python functions using ctx.activity() and ctx.sleep(). On each step, we replay from the start and use the event log (HistoryEvent) to return prior results. Avoid non-deterministic branching not derived from previous results or inputs.

Activity and workflow results must be JSON-serializable.

Commands

python manage.py durable_start onboard_user --input '{"user_id": 7}'

python manage.py durable_worker --batch 20 --tick 0.2

Signals

• In code, a workflow can wait for signals using ctx.wait_signal("signal_name"), which pauses execution until a matching signal arrives and returns its payload.
• To send a signal from outside code:

python manage.py durable_signal <execution_uuid> user_clicked --input '{"clicked": true}'

You can also send a signal programmatically:

from django_durable.engine import send_signal
send_signal(execution_id, "user_clicked", {"clicked": True})

Cancellation

• Cancel a workflow via CLI:

python manage.py durable_cancel <execution_uuid> --reason "user requested" [--keep-queued]

• In code:

from django_durable.engine import cancel_workflow
cancel_workflow(execution_id, reason="user requested")

Cancellation moves the workflow to CANCELED and, by default, marks queued activities as failed so workers will not run them.