schema.sql

-- gue table, copy of https://github.com/vgarvardt/gue/blob/master/migrations/schema.sql
CREATE TABLE IF NOT EXISTS gue_jobs
(
    job_id      TEXT        NOT NULL PRIMARY KEY,
    priority    SMALLINT    NOT NULL,
    run_at      TIMESTAMPTZ NOT NULL,
    job_type    TEXT        NOT NULL,
    args        BYTEA       NOT NULL,
    error_count INTEGER     NOT NULL DEFAULT 0,
    last_error  TEXT,
    queue       TEXT        NOT NULL,
    created_at  TIMESTAMPTZ NOT NULL,
    updated_at  TIMESTAMPTZ NOT NULL
);

CREATE INDEX IF NOT EXISTS idx_gue_jobs_selector ON gue_jobs (queue, run_at, priority);

-- gueron table
CREATE TABLE IF NOT EXISTS gueron_meta
(
    queue        TEXT        NOT NULL PRIMARY KEY,
    hash         TEXT        NOT NULL,
    scheduled_at TIMESTAMPTZ NOT NULL,
    horizon_at   TIMESTAMPTZ NOT NULL
);