CREATE TABLE que_jobs (
priority integer NOT NULL DEFAULT 1, run_at timestamptz NOT NULL DEFAULT now(), job_id bigserial NOT NULL, job_class text NOT NULL, args json NOT NULL DEFAULT '[]'::json, error_count integer NOT NULL DEFAULT 0, last_error text, CONSTRAINT que_jobs_pkey PRIMARY KEY (priority, run_at, job_id)
);