103 lines
4.3 KiB
Ruby
103 lines
4.3 KiB
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
class CreateGoodJobs < ActiveRecord::Migration[7.1]
|
||
|
|
def change
|
||
|
|
# Uncomment for Postgres v12 or earlier to enable gen_random_uuid() support
|
||
|
|
# enable_extension 'pgcrypto'
|
||
|
|
|
||
|
|
create_table(:good_jobs, id: :uuid) do |t|
|
||
|
|
t.text(:queue_name)
|
||
|
|
t.integer(:priority)
|
||
|
|
t.jsonb(:serialized_params)
|
||
|
|
t.datetime(:scheduled_at)
|
||
|
|
t.datetime(:performed_at)
|
||
|
|
t.datetime(:finished_at)
|
||
|
|
t.text(:error)
|
||
|
|
|
||
|
|
t.timestamps
|
||
|
|
|
||
|
|
t.uuid(:active_job_id)
|
||
|
|
t.text(:concurrency_key)
|
||
|
|
t.text(:cron_key)
|
||
|
|
t.uuid(:retried_good_job_id)
|
||
|
|
t.datetime(:cron_at)
|
||
|
|
|
||
|
|
t.uuid(:batch_id)
|
||
|
|
t.uuid(:batch_callback_id)
|
||
|
|
|
||
|
|
t.boolean(:is_discrete) # rubocop:disable Rails/ThreeStateBooleanColumn
|
||
|
|
t.integer(:executions_count)
|
||
|
|
t.text(:job_class)
|
||
|
|
t.integer(:error_event, limit: 2)
|
||
|
|
t.text(:labels, array: true)
|
||
|
|
t.uuid(:locked_by_id)
|
||
|
|
t.datetime(:locked_at)
|
||
|
|
end
|
||
|
|
|
||
|
|
create_table(:good_job_batches, id: :uuid) do |t|
|
||
|
|
t.timestamps
|
||
|
|
t.text(:description)
|
||
|
|
t.jsonb(:serialized_properties)
|
||
|
|
t.text(:on_finish)
|
||
|
|
t.text(:on_success)
|
||
|
|
t.text(:on_discard)
|
||
|
|
t.text(:callback_queue_name)
|
||
|
|
t.integer(:callback_priority)
|
||
|
|
t.datetime(:enqueued_at)
|
||
|
|
t.datetime(:discarded_at)
|
||
|
|
t.datetime(:finished_at)
|
||
|
|
end
|
||
|
|
|
||
|
|
create_table(:good_job_executions, id: :uuid) do |t|
|
||
|
|
t.timestamps
|
||
|
|
|
||
|
|
t.uuid(:active_job_id, null: false)
|
||
|
|
t.text(:job_class)
|
||
|
|
t.text(:queue_name)
|
||
|
|
t.jsonb(:serialized_params)
|
||
|
|
t.datetime(:scheduled_at)
|
||
|
|
t.datetime(:finished_at)
|
||
|
|
t.text(:error)
|
||
|
|
t.integer(:error_event, limit: 2)
|
||
|
|
t.text(:error_backtrace, array: true)
|
||
|
|
t.uuid(:process_id)
|
||
|
|
t.interval(:duration)
|
||
|
|
end
|
||
|
|
|
||
|
|
create_table(:good_job_processes, id: :uuid) do |t|
|
||
|
|
t.timestamps
|
||
|
|
t.jsonb(:state)
|
||
|
|
t.integer(:lock_type, limit: 2)
|
||
|
|
end
|
||
|
|
|
||
|
|
create_table(:good_job_settings, id: :uuid) do |t|
|
||
|
|
t.timestamps
|
||
|
|
t.text(:key)
|
||
|
|
t.jsonb(:value)
|
||
|
|
t.index(:key, unique: true)
|
||
|
|
end
|
||
|
|
|
||
|
|
add_index(:good_jobs, :scheduled_at, where: "(finished_at IS NULL)", name: :index_good_jobs_on_scheduled_at)
|
||
|
|
add_index(:good_jobs, %i[queue_name scheduled_at], where: "(finished_at IS NULL)", name: :index_good_jobs_on_queue_name_and_scheduled_at)
|
||
|
|
add_index(:good_jobs, %i[active_job_id created_at], name: :index_good_jobs_on_active_job_id_and_created_at)
|
||
|
|
add_index(:good_jobs, :concurrency_key, where: "(finished_at IS NULL)", name: :index_good_jobs_on_concurrency_key_when_unfinished)
|
||
|
|
add_index(:good_jobs, %i[cron_key created_at], where: "(cron_key IS NOT NULL)", name: :index_good_jobs_on_cron_key_and_created_at_cond)
|
||
|
|
add_index(:good_jobs, %i[cron_key cron_at], where: "(cron_key IS NOT NULL)", unique: true, name: :index_good_jobs_on_cron_key_and_cron_at_cond)
|
||
|
|
add_index(:good_jobs, [:finished_at], where: "retried_good_job_id IS NULL AND finished_at IS NOT NULL", name: :index_good_jobs_jobs_on_finished_at)
|
||
|
|
add_index(:good_jobs, %i[priority created_at], order: { priority: "DESC NULLS LAST", created_at: :asc },
|
||
|
|
where: "finished_at IS NULL", name: :index_good_jobs_jobs_on_priority_created_at_when_unfinished)
|
||
|
|
add_index(:good_jobs, %i[priority created_at], order: { priority: "ASC NULLS LAST", created_at: :asc },
|
||
|
|
where: "finished_at IS NULL", name: :index_good_job_jobs_for_candidate_lookup)
|
||
|
|
add_index(:good_jobs, [:batch_id], where: "batch_id IS NOT NULL")
|
||
|
|
add_index(:good_jobs, [:batch_callback_id], where: "batch_callback_id IS NOT NULL")
|
||
|
|
add_index(:good_jobs, :labels, using: :gin, where: "(labels IS NOT NULL)", name: :index_good_jobs_on_labels)
|
||
|
|
|
||
|
|
add_index(:good_job_executions, %i[active_job_id created_at], name: :index_good_job_executions_on_active_job_id_and_created_at)
|
||
|
|
add_index(:good_jobs, %i[priority scheduled_at], order: { priority: "ASC NULLS LAST", scheduled_at: :asc },
|
||
|
|
where: "finished_at IS NULL AND locked_by_id IS NULL", name: :index_good_jobs_on_priority_scheduled_at_unfinished_unlocked)
|
||
|
|
add_index(:good_jobs, :locked_by_id,
|
||
|
|
where: "locked_by_id IS NOT NULL", name: "index_good_jobs_on_locked_by_id")
|
||
|
|
add_index(:good_job_executions, %i[process_id created_at], name: :index_good_job_executions_on_process_id_and_created_at)
|
||
|
|
end
|
||
|
|
end
|