11class CreateSolidQueueTables < ActiveRecord ::Migration [ 7.2 ]
22 create_table "solid_queue_blocked_executions" , if_not_exists : true do |t |
3- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
3+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
44 t . string "queue_name" , null : false
55 t . integer "priority" , default : 0 , null : false
66 t . string "concurrency_key" , null : false
@@ -11,14 +11,14 @@ class CreateSolidQueueTables < ActiveRecord::Migration[7.2]
1111 end
1212
1313 create_table "solid_queue_claimed_executions" , if_not_exists : true do |t |
14- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
15- t . bigint "process_id"
14+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
15+ t . references :process
1616 t . datetime "created_at" , null : false
1717 t . index [ "process_id" , "job_id" ] , name : "index_solid_queue_claimed_executions_on_process_id_and_job_id"
1818 end
1919
2020 create_table "solid_queue_failed_executions" , if_not_exists : true do |t |
21- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
21+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
2222 t . text "error"
2323 t . datetime "created_at" , null : false
2424 end
@@ -46,7 +46,7 @@ class CreateSolidQueueTables < ActiveRecord::Migration[7.2]
4646 create_table "solid_queue_processes" , if_not_exists : true do |t |
4747 t . string "kind" , null : false
4848 t . datetime "last_heartbeat_at" , null : false , index : true
49- t . bigint "supervisor_id" , index : true
49+ t . references :supervisor
5050 t . integer "pid" , null : false
5151 t . string "hostname"
5252 t . text "metadata"
@@ -56,7 +56,7 @@ class CreateSolidQueueTables < ActiveRecord::Migration[7.2]
5656 end
5757
5858 create_table "solid_queue_ready_executions" , if_not_exists : true do |t |
59- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
59+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
6060 t . string "queue_name" , null : false
6161 t . integer "priority" , default : 0 , null : false
6262 t . datetime "created_at" , null : false
@@ -65,7 +65,7 @@ class CreateSolidQueueTables < ActiveRecord::Migration[7.2]
6565 end
6666
6767 create_table "solid_queue_recurring_executions" , if_not_exists : true do |t |
68- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
68+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
6969 t . string "task_key" , null : false
7070 t . datetime "run_at" , null : false
7171 t . datetime "created_at" , null : false
@@ -87,7 +87,7 @@ class CreateSolidQueueTables < ActiveRecord::Migration[7.2]
8787 end
8888
8989 create_table "solid_queue_scheduled_executions" , if_not_exists : true do |t |
90- t . bigint "job_id" , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
90+ t . references :job , null : false , index : { unique : true } , foreign_key : { to_table : :solid_queue_jobs , on_delete : :cascade }
9191 t . string "queue_name" , null : false
9292 t . integer "priority" , default : 0 , null : false
9393 t . datetime "scheduled_at" , null : false
0 commit comments