Modules
OTP-native durable execution engine for Elixir.
Defines an activity — the only place where side effects are allowed.
Handle for a successful activity that carries a compensation (saga DSL).
Compile-time AST scanner that rejects calls known to be non-deterministic inside workflow code.
Handle for an asynchronously started child workflow.
Raised when a workflow primitive is invoked outside a workflow process.
Data and action helpers for the optional Continuum Observer.
Router macro for mounting the optional Continuum Observer.
Optional OpenTelemetry bridge for Continuum telemetry events.
Mark a module as a pure helper that may be called from workflow code.
Structured read API for durable run rows.
Raised when the journaled history at the current cursor doesn't match the effect that the workflow code is now requesting. Indicates a non-trivial code change between original execution and replay.
Polls continuum_activity_tasks, leases available tasks, and starts workers.
Dynamic supervisor for activity worker processes.
Executes one leased activity task.
Per-run effect context, kept in the workflow process's process dictionary.
Polls Postgres for runnable workflow runs and starts local engines.
The bridge between workflow code and the engine.
GenServer-per-run. The heart of replay.
Behaviour for the event-history journal.
In-memory journal backed by a single GenServer.
Durable journal adapter backed by Postgres via Ecto.
Postgres lease acquisition and renewal for workflow runs.
Renews leases owned by local workflow engines.
Boot-time recovery for orphaned durable work.
DynamicSupervisor that owns one Continuum.Runtime.Engine process per
active run.
Routes external signals and child-completion wakeups to workflow processes.
Caches near-term durable timers and wakes runs when timers fire.
Compacted history prefix for long-running workflows.
Telemetry event names emitted by Continuum.
Public helpers for testing Continuum workflows.
Determinism safety net for the test suite — the --paranoid re-replay mode.
Raised when a durable run references a workflow version that is not loaded.
Registry for workflow version hashes and callable entrypoints.
Defines a durable workflow.
Mix Tasks
Deletes expired non-tail runs from continue_as_new chains.
Audits loaded Continuum workflows and durable patch markers.
Lists or deletes unreferenced workflow-version registry rows.
Generates a Continuum activity module.
Generates the Ecto migration that creates Continuum's Postgres tables.
Generates a Continuum workflow module.
Creates a monthly continuum_events partition.
Drops old continuum_events partitions whose rows all belong to expired runs.
Lists managed continuum_events partitions and their row counts.