module Divider::Migrations

The schema of the queue, as rotor migrations (Rotor::Migration): an application adds Divider::Migrations.all to its migrator's list.

def migrate(repo: Rotor::Repo, app: Array[Type[Rotor::Migration]]) -> Void
  Rotor::Migrator.new(repo, app + Divider::Migrations.all).migrate
end

Their versions are fixed (2026110800000N), so that every database that ran one knows it by the same number; later versions of divider add migrations, never change these.

/home/runner/work/divider/divider/src/migrations.qz:13

Classes and modules

• Divider::Migrations::CreateCron The table divider_cron: for each cron entry (by a digest of its expression, class and arguments), the last minute a worker enqueued it for, so that one worker enqueues it once per minute.
• Divider::Migrations::CreateJobs The table divider_jobs and its indexes: one row a job, from its insertion until it is pruned. States: scheduled, available, running, completed, failed (a retry pending, at scheduled_at), discarded, cancelled. A running job whose cancelled_at is set was asked to stop (Divider.cancel).

Class methods