From 1b66602eeab6d7ed8f2aaf1107826c84d765e1da Mon Sep 17 00:00:00 2001 From: Rosa Gutierrez Date: Tue, 7 Nov 2023 11:55:59 +0100 Subject: [PATCH] Tweak indexes in blocked_executions table --- ...20231103204612_create_solid_queue_concurrency_controls.rb | 5 ++++- test/dummy/db/schema.rb | 5 ++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb b/db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb index c1b9ec28..9007ca04 100644 --- a/db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb +++ b/db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb @@ -11,9 +11,12 @@ def change t.integer :priority, default: 0, null: false t.integer :concurrency_limit, null: false - t.string :concurrency_key, null: false, index: true + t.string :concurrency_key, null: false t.datetime :created_at, null: false + + t.index [ :concurrency_key, :priority ] + t.index [ :queue_name, :concurrency_key ] end create_table :solid_queue_semaphores do |t| diff --git a/test/dummy/db/schema.rb b/test/dummy/db/schema.rb index 83a0e892..875ad333 100644 --- a/test/dummy/db/schema.rb +++ b/test/dummy/db/schema.rb @@ -26,8 +26,9 @@ t.integer "concurrency_limit", null: false t.string "concurrency_key", null: false t.datetime "created_at", null: false - t.index ["concurrency_key"], name: "index_solid_queue_blocked_executions_on_concurrency_key" + t.index ["concurrency_key", "priority"], name: "idx_on_concurrency_key_priority_1d18ad1bbb" t.index ["job_id"], name: "index_solid_queue_blocked_executions_on_job_id", unique: true + t.index ["queue_name", "concurrency_key"], name: "idx_on_queue_name_concurrency_key_6fea8d37ab" end create_table "solid_queue_claimed_executions", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t| @@ -82,6 +83,8 @@ t.string "queue_name", null: false t.integer "priority", default: 0, null: false t.datetime "created_at", null: false + t.string "concurrency_key" + t.index ["concurrency_key"], name: "index_solid_queue_ready_executions_on_concurrency_key" t.index ["job_id"], name: "index_solid_queue_ready_executions_on_job_id", unique: true t.index ["priority"], name: "index_solid_queue_ready_executions_on_priority" t.index ["queue_name", "priority"], name: "index_solid_queue_ready_executions"