diff --git a/db/migrate/20240313184443_create_solid_queue_tables.solid_queue.rb b/db/migrate/20240313184443_create_solid_queue_tables.solid_queue.rb index 6d8c4f6..2591b73 100644 --- a/db/migrate/20240313184443_create_solid_queue_tables.solid_queue.rb +++ b/db/migrate/20240313184443_create_solid_queue_tables.solid_queue.rb @@ -13,42 +13,42 @@ def change t.timestamps - t.index [ :queue_name, :finished_at ], name: "index_solid_queue_jobs_for_filtering" - t.index [ :scheduled_at, :finished_at ], name: "index_solid_queue_jobs_for_alerting" + t.index [:queue_name, :finished_at], name: "index_solid_queue_jobs_for_filtering" + t.index [:scheduled_at, :finished_at], name: "index_solid_queue_jobs_for_alerting" end create_table :solid_queue_scheduled_executions do |t| - t.references :job, index: { unique: true }, null: false + t.references :job, index: {unique: true}, null: false t.string :queue_name, null: false t.integer :priority, default: 0, null: false t.datetime :scheduled_at, null: false t.datetime :created_at, null: false - t.index [ :scheduled_at, :priority, :job_id ], name: "index_solid_queue_dispatch_all" + t.index [:scheduled_at, :priority, :job_id], name: "index_solid_queue_dispatch_all" end create_table :solid_queue_ready_executions do |t| - t.references :job, index: { unique: true }, null: false + t.references :job, index: {unique: true}, null: false t.string :queue_name, null: false t.integer :priority, default: 0, null: false t.datetime :created_at, null: false - t.index [ :priority, :job_id ], name: "index_solid_queue_poll_all" - t.index [ :queue_name, :priority, :job_id ], name: "index_solid_queue_poll_by_queue" + t.index [:priority, :job_id], name: "index_solid_queue_poll_all" + t.index [:queue_name, :priority, :job_id], name: "index_solid_queue_poll_by_queue" end create_table :solid_queue_claimed_executions do |t| - t.references :job, index: { unique: true }, null: false + t.references :job, index: {unique: true}, null: false t.bigint :process_id t.datetime :created_at, null: false - t.index [ :process_id, :job_id ] + t.index [:process_id, :job_id] end create_table :solid_queue_blocked_executions do |t| - t.references :job, index: { unique: true }, null: false + t.references :job, index: {unique: true}, null: false t.string :queue_name, null: false t.integer :priority, default: 0, null: false t.string :concurrency_key, null: false @@ -56,17 +56,17 @@ def change t.datetime :created_at, null: false - t.index [ :expires_at, :concurrency_key ], name: "index_solid_queue_blocked_executions_for_maintenance" + t.index [:expires_at, :concurrency_key], name: "index_solid_queue_blocked_executions_for_maintenance" end create_table :solid_queue_failed_executions do |t| - t.references :job, index: { unique: true }, null: false + t.references :job, index: {unique: true}, null: false t.text :error t.datetime :created_at, null: false end create_table :solid_queue_pauses do |t| - t.string :queue_name, null: false, index: { unique: true } + t.string :queue_name, null: false, index: {unique: true} t.datetime :created_at, null: false end @@ -83,13 +83,13 @@ def change end create_table :solid_queue_semaphores do |t| - t.string :key, null: false, index: { unique: true } + t.string :key, null: false, index: {unique: true} t.integer :value, default: 1, null: false t.datetime :expires_at, null: false, index: true t.timestamps - t.index [ :key, :value ], name: "index_solid_queue_semaphores_on_key_and_value" + t.index [:key, :value], name: "index_solid_queue_semaphores_on_key_and_value" end add_foreign_key :solid_queue_blocked_executions, :solid_queue_jobs, column: :job_id, on_delete: :cascade diff --git a/db/migrate/20240313184444_add_missing_index_to_blocked_executions.solid_queue.rb b/db/migrate/20240313184444_add_missing_index_to_blocked_executions.solid_queue.rb index 2d96b10..53e74dc 100644 --- a/db/migrate/20240313184444_add_missing_index_to_blocked_executions.solid_queue.rb +++ b/db/migrate/20240313184444_add_missing_index_to_blocked_executions.solid_queue.rb @@ -1,6 +1,6 @@ # This migration comes from solid_queue (originally 20240110143450) class AddMissingIndexToBlockedExecutions < ActiveRecord::Migration[7.1] def change - add_index :solid_queue_blocked_executions, [ :concurrency_key, :priority, :job_id ], name: "index_solid_queue_blocked_executions_for_release" + add_index :solid_queue_blocked_executions, [:concurrency_key, :priority, :job_id], name: "index_solid_queue_blocked_executions_for_release" end end