Modules
OTP-native durable execution engine for Elixir.
Defines an activity — the only place where side effects are allowed.
Validated, normalized execution policy for an activity call.
Operator-facing inspection, classification, dead-letter, and manual retry API.
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.
Validates values before they cross a Continuum journal boundary.
Raised when a value contains a node-local term that cannot be replayed durably.
Read-only operational health reporting and explicitly fenced repairs.
Raised when a workflow primitive is invoked outside a workflow process.
Optional Oban activity executor integration.
Data and action helpers for the optional Continuum Observer.
Router macro for mounting the optional Continuum Observer.
Optional OpenTelemetry bridge for Continuum telemetry events.
Maintains the monthly continuum_events partition horizon.
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.
Stable public description of a failed workflow run.
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.
Raised by a journal adapter when a write is rejected or fails.
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.
Raised when workflow code swallows Continuum's suspend control throw.
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
Inspects activity attempt lineages and performs audited operator actions.
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.
Reports operational health and plans or executes fenced repairs.
Ensures a horizon of monthly continuum_events partitions.
Drops old continuum_events partitions whose rows all belong to expired runs.
Lists managed continuum_events partitions and their row counts.