|
18 | 18 | t.string "concurrency_key", null: false |
19 | 19 | t.datetime "expires_at", precision: nil, null: false |
20 | 20 | t.datetime "created_at", precision: nil, null: false |
21 | | - t.index [ "concurrency_key", "priority", "job_id" ], |
22 | | -name: "index_solid_queue_blocked_executions_for_release" |
23 | | - t.index [ "expires_at", "concurrency_key" ], |
24 | | -name: "index_solid_queue_blocked_executions_for_maintenance" |
25 | | - t.index [ "job_id" ], name: "index_solid_queue_blocked_executions_on_job_id", unique: true |
| 21 | + t.index ["concurrency_key", "priority", "job_id"], name: "index_solid_queue_blocked_executions_for_release" |
| 22 | + t.index ["expires_at", "concurrency_key"], name: "index_solid_queue_blocked_executions_for_maintenance" |
| 23 | + t.index ["job_id"], name: "index_solid_queue_blocked_executions_on_job_id", unique: true |
26 | 24 | end |
27 | 25 |
|
28 | 26 | create_table "solid_queue_claimed_executions", force: :cascade do |t| |
29 | 27 | t.bigint "job_id", null: false |
30 | 28 | t.bigint "process_id" |
31 | 29 | t.datetime "created_at", precision: nil, null: false |
32 | | - t.index [ "job_id" ], name: "index_solid_queue_claimed_executions_on_job_id", unique: true |
33 | | - t.index [ "process_id", "job_id" ], |
34 | | -name: "index_solid_queue_claimed_executions_on_process_id_and_job_id" |
| 30 | + t.index ["job_id"], name: "index_solid_queue_claimed_executions_on_job_id", unique: true |
| 31 | + t.index ["process_id", "job_id"], name: "index_solid_queue_claimed_executions_on_process_id_and_job_id" |
35 | 32 | end |
36 | 33 |
|
37 | 34 | create_table "solid_queue_failed_executions", force: :cascade do |t| |
38 | 35 | t.bigint "job_id", null: false |
39 | 36 | t.text "error" |
40 | 37 | t.datetime "created_at", precision: nil, null: false |
41 | | - t.index [ "job_id" ], name: "index_solid_queue_failed_executions_on_job_id", unique: true |
| 38 | + t.index ["job_id"], name: "index_solid_queue_failed_executions_on_job_id", unique: true |
42 | 39 | end |
43 | 40 |
|
44 | 41 | create_table "solid_queue_jobs", force: :cascade do |t| |
|
52 | 49 | t.string "concurrency_key" |
53 | 50 | t.datetime "created_at", precision: nil, null: false |
54 | 51 | t.datetime "updated_at", precision: nil, null: false |
55 | | - t.index [ "active_job_id" ], name: "index_solid_queue_jobs_on_active_job_id" |
56 | | - t.index [ "class_name" ], name: "index_solid_queue_jobs_on_class_name" |
57 | | - t.index [ "finished_at" ], name: "index_solid_queue_jobs_on_finished_at" |
58 | | - t.index [ "queue_name", "finished_at" ], name: "index_solid_queue_jobs_for_filtering" |
59 | | - t.index [ "scheduled_at", "finished_at" ], name: "index_solid_queue_jobs_for_alerting" |
| 52 | + t.index ["active_job_id"], name: "index_solid_queue_jobs_on_active_job_id" |
| 53 | + t.index ["class_name"], name: "index_solid_queue_jobs_on_class_name" |
| 54 | + t.index ["finished_at"], name: "index_solid_queue_jobs_on_finished_at" |
| 55 | + t.index ["queue_name", "finished_at"], name: "index_solid_queue_jobs_for_filtering" |
| 56 | + t.index ["scheduled_at", "finished_at"], name: "index_solid_queue_jobs_for_alerting" |
60 | 57 | end |
61 | 58 |
|
62 | 59 | create_table "solid_queue_pauses", force: :cascade do |t| |
63 | 60 | t.string "queue_name", null: false |
64 | 61 | t.datetime "created_at", precision: nil, null: false |
65 | | - t.index [ "queue_name" ], name: "index_solid_queue_pauses_on_queue_name", unique: true |
| 62 | + t.index ["queue_name"], name: "index_solid_queue_pauses_on_queue_name", unique: true |
66 | 63 | end |
67 | 64 |
|
68 | 65 | create_table "solid_queue_processes", force: :cascade do |t| |
|
74 | 71 | t.text "metadata" |
75 | 72 | t.datetime "created_at", precision: nil, null: false |
76 | 73 | t.string "name", null: false |
77 | | - t.index [ "last_heartbeat_at" ], name: "index_solid_queue_processes_on_last_heartbeat_at" |
78 | | - t.index [ "name", "supervisor_id" ], |
79 | | -name: "index_solid_queue_processes_on_name_and_supervisor_id", unique: true |
80 | | - t.index [ "supervisor_id" ], name: "index_solid_queue_processes_on_supervisor_id" |
| 74 | + 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 |
| 76 | + t.index ["supervisor_id"], name: "index_solid_queue_processes_on_supervisor_id" |
81 | 77 | end |
82 | 78 |
|
83 | 79 | create_table "solid_queue_ready_executions", force: :cascade do |t| |
84 | 80 | t.bigint "job_id", null: false |
85 | 81 | t.string "queue_name", null: false |
86 | 82 | t.integer "priority", default: 0, null: false |
87 | 83 | t.datetime "created_at", precision: nil, null: false |
88 | | - t.index [ "job_id" ], name: "index_solid_queue_ready_executions_on_job_id", unique: true |
89 | | - t.index [ "priority", "job_id" ], name: "index_solid_queue_poll_all" |
90 | | - t.index [ "queue_name", "priority", "job_id" ], name: "index_solid_queue_poll_by_queue" |
| 84 | + t.index ["job_id"], name: "index_solid_queue_ready_executions_on_job_id", unique: true |
| 85 | + t.index ["priority", "job_id"], name: "index_solid_queue_poll_all" |
| 86 | + t.index ["queue_name", "priority", "job_id"], name: "index_solid_queue_poll_by_queue" |
91 | 87 | end |
92 | 88 |
|
93 | 89 | create_table "solid_queue_recurring_executions", force: :cascade do |t| |
94 | 90 | t.bigint "job_id", null: false |
95 | 91 | t.string "task_key", null: false |
96 | 92 | t.datetime "run_at", precision: nil, null: false |
97 | 93 | t.datetime "created_at", precision: nil, null: false |
98 | | - t.index [ "job_id" ], name: "index_solid_queue_recurring_executions_on_job_id", unique: true |
99 | | - t.index [ "task_key", "run_at" ], |
100 | | -name: "index_solid_queue_recurring_executions_on_task_key_and_run_at", unique: true |
| 94 | + t.index ["job_id"], name: "index_solid_queue_recurring_executions_on_job_id", unique: true |
| 95 | + t.index ["task_key", "run_at"], name: "index_solid_queue_recurring_executions_on_task_key_and_run_at", unique: true |
101 | 96 | end |
102 | 97 |
|
103 | 98 | create_table "solid_queue_recurring_tasks", force: :cascade do |t| |
|
112 | 107 | t.text "description" |
113 | 108 | t.datetime "created_at", precision: nil, null: false |
114 | 109 | t.datetime "updated_at", precision: nil, null: false |
115 | | - t.index [ "key" ], name: "index_solid_queue_recurring_tasks_on_key", unique: true |
116 | | - t.index [ "static" ], name: "index_solid_queue_recurring_tasks_on_static" |
| 110 | + t.index ["key"], name: "index_solid_queue_recurring_tasks_on_key", unique: true |
| 111 | + t.index ["static"], name: "index_solid_queue_recurring_tasks_on_static" |
117 | 112 | end |
118 | 113 |
|
119 | 114 | create_table "solid_queue_scheduled_executions", force: :cascade do |t| |
|
122 | 117 | t.integer "priority", default: 0, null: false |
123 | 118 | t.datetime "scheduled_at", precision: nil, null: false |
124 | 119 | t.datetime "created_at", precision: nil, null: false |
125 | | - t.index [ "job_id" ], name: "index_solid_queue_scheduled_executions_on_job_id", unique: true |
126 | | - t.index [ "scheduled_at", "priority", "job_id" ], name: "index_solid_queue_dispatch_all" |
| 120 | + t.index ["job_id"], name: "index_solid_queue_scheduled_executions_on_job_id", unique: true |
| 121 | + t.index ["scheduled_at", "priority", "job_id"], name: "index_solid_queue_dispatch_all" |
127 | 122 | end |
128 | 123 |
|
129 | 124 | create_table "solid_queue_semaphores", force: :cascade do |t| |
|
132 | 127 | t.datetime "expires_at", precision: nil, null: false |
133 | 128 | t.datetime "created_at", precision: nil, null: false |
134 | 129 | t.datetime "updated_at", precision: nil, null: false |
135 | | - t.index [ "expires_at" ], name: "index_solid_queue_semaphores_on_expires_at" |
136 | | - t.index [ "key", "value" ], name: "index_solid_queue_semaphores_on_key_and_value" |
137 | | - t.index [ "key" ], name: "index_solid_queue_semaphores_on_key", unique: true |
| 130 | + t.index ["expires_at"], name: "index_solid_queue_semaphores_on_expires_at" |
| 131 | + t.index ["key", "value"], name: "index_solid_queue_semaphores_on_key_and_value" |
| 132 | + t.index ["key"], name: "index_solid_queue_semaphores_on_key", unique: true |
138 | 133 | end |
139 | 134 |
|
140 | | - add_foreign_key "solid_queue_blocked_executions", "solid_queue_jobs", column: "job_id", |
141 | | -on_delete: :cascade |
142 | | - add_foreign_key "solid_queue_claimed_executions", "solid_queue_jobs", column: "job_id", |
143 | | -on_delete: :cascade |
144 | | - add_foreign_key "solid_queue_failed_executions", "solid_queue_jobs", column: "job_id", |
145 | | -on_delete: :cascade |
146 | | - add_foreign_key "solid_queue_ready_executions", "solid_queue_jobs", column: "job_id", |
147 | | -on_delete: :cascade |
148 | | - add_foreign_key "solid_queue_recurring_executions", "solid_queue_jobs", column: "job_id", |
149 | | -on_delete: :cascade |
150 | | - add_foreign_key "solid_queue_scheduled_executions", "solid_queue_jobs", column: "job_id", |
151 | | -on_delete: :cascade |
| 135 | + add_foreign_key "solid_queue_blocked_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
| 136 | + add_foreign_key "solid_queue_claimed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
| 137 | + add_foreign_key "solid_queue_failed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
| 138 | + add_foreign_key "solid_queue_ready_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
| 139 | + add_foreign_key "solid_queue_recurring_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
| 140 | + add_foreign_key "solid_queue_scheduled_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade |
152 | 141 | end |
0 commit comments