Skip to content

Commit cad5b99

Browse files
committed
Tweak indexes in blocked_executions table
1 parent 0f4d809 commit cad5b99

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb

+4-1
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,12 @@ def change
1111
t.integer :priority, default: 0, null: false
1212

1313
t.integer :concurrency_limit, null: false
14-
t.string :concurrency_key, null: false, index: true
14+
t.string :concurrency_key, null: false
1515

1616
t.datetime :created_at, null: false
17+
18+
t.index [ :concurrency_key, :priority ], name: "index_solid_queue_blocked_executions_for_release"
19+
t.index [ :queue_name, :concurrency_key ], name: "index_solid_queue_blocked_executions_for_polling"
1720
end
1821

1922
create_table :solid_queue_semaphores do |t|

test/dummy/db/schema.rb

+4-1
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,9 @@
2626
t.integer "concurrency_limit", null: false
2727
t.string "concurrency_key", null: false
2828
t.datetime "created_at", null: false
29-
t.index ["concurrency_key"], name: "index_solid_queue_blocked_executions_on_concurrency_key"
29+
t.index ["concurrency_key", "priority"], name: "index_solid_queue_blocked_executions_for_release"
3030
t.index ["job_id"], name: "index_solid_queue_blocked_executions_on_job_id", unique: true
31+
t.index ["queue_name", "concurrency_key"], name: "index_solid_queue_blocked_executions_for_polling"
3132
end
3233

3334
create_table "solid_queue_claimed_executions", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
@@ -82,6 +83,8 @@
8283
t.string "queue_name", null: false
8384
t.integer "priority", default: 0, null: false
8485
t.datetime "created_at", null: false
86+
t.string "concurrency_key"
87+
t.index ["concurrency_key"], name: "index_solid_queue_ready_executions_on_concurrency_key"
8588
t.index ["job_id"], name: "index_solid_queue_ready_executions_on_job_id", unique: true
8689
t.index ["priority"], name: "index_solid_queue_ready_executions_on_priority"
8790
t.index ["queue_name", "priority"], name: "index_solid_queue_ready_executions"

0 commit comments

Comments
 (0)