Modules
Public API of the Sig workflow engine.
Enqueues workflow nodes as BullMQ jobs.
Starts the Redis connection and the BullMQ worker that process asynchronous executions.
Processes the BullMQ jobs enqueued by Sig.BullMQ.Queue.
The execution engine behind Sig.
A small builder for workflow definitions, plus the DAG helpers used by the engine.
Creates and upgrades Sig's database tables from your application's own migrations.
Behaviour for workflow nodes.
The data a node receives when it runs.
Delegates Sig's database calls to your application's Ecto repo.
The record of one node within a workflow execution.
A persisted workflow definition.
A single run of a workflow.
Converts Elixir terms into JSON-safe values for storage in PostgreSQL JSONB columns.