Skip to content

Commit 677fa5f

Browse files
committed
Apply update and new migration to Dummy app
1 parent 15746bb commit 677fa5f

File tree

2 files changed

+34
-2
lines changed

2 files changed

+34
-2
lines changed
Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
class LinkClaimedExecutionsWithProcessesThroughName < ActiveRecord::Migration[7.1]
2+
def up
3+
unless connection.column_exists?(:solid_queue_claimed_executions, :process_name)
4+
add_column :solid_queue_claimed_executions, :process_name, :string
5+
add_index :solid_queue_claimed_executions, :process_name
6+
end
7+
8+
unless connection.index_exists?(:solid_queue_processes, :name)
9+
add_index :solid_queue_processes, :name, unique: true
10+
end
11+
12+
if connection.index_exists?(:solid_queue_processes, [ :name, :supervisor_id ])
13+
remove_index :solid_queue_processes, [ :name, :supervisor_id ]
14+
end
15+
end
16+
17+
def down
18+
if connection.column_exists?(:solid_queue_claimed_executions, :process_name)
19+
remove_column :solid_queue_claimed_executions, :process_name
20+
end
21+
22+
if connection.index_exists?(:solid_queue_processes, :name)
23+
remove_index :solid_queue_processes, :name
24+
end
25+
26+
unless connection.index_exists?(:solid_queue_processes, [ :name, :supervisor_id ])
27+
add_index :solid_queue_processes, [ :name, :supervisor_id ], unique: true
28+
end
29+
end
30+
end

test/dummy/db/queue_schema.rb

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
#
1111
# It's strongly recommended that you check this file into your version control system.
1212

13-
ActiveRecord::Schema[7.1].define(version: 1) do
13+
ActiveRecord::Schema[7.1].define(version: 2025_07_20_172253) do
1414
create_table "solid_queue_blocked_executions", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
1515
t.bigint "job_id", null: false
1616
t.string "queue_name", null: false
@@ -27,8 +27,10 @@
2727
t.bigint "job_id", null: false
2828
t.bigint "process_id"
2929
t.datetime "created_at", null: false
30+
t.string "process_name"
3031
t.index ["job_id"], name: "index_solid_queue_claimed_executions_on_job_id", unique: true
3132
t.index ["process_id", "job_id"], name: "index_solid_queue_claimed_executions_on_process_id_and_job_id"
33+
t.index ["process_name"], name: "index_solid_queue_claimed_executions_on_process_name"
3234
end
3335

3436
create_table "solid_queue_failed_executions", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
@@ -72,7 +74,7 @@
7274
t.datetime "created_at", null: false
7375
t.string "name", null: false
7476
t.index ["last_heartbeat_at"], name: "index_solid_queue_processes_on_last_heartbeat_at"
75-
t.index ["name", "supervisor_id"], name: "index_solid_queue_processes_on_name_and_supervisor_id", unique: true
77+
t.index ["name"], name: "index_solid_queue_processes_on_name", unique: true
7678
t.index ["supervisor_id"], name: "index_solid_queue_processes_on_supervisor_id"
7779
end
7880

0 commit comments

Comments
 (0)