|
38 | 38 | t.index ["job_id"], name: "index_solid_queue_failed_executions_on_job_id", unique: true
|
39 | 39 | end
|
40 | 40 |
|
| 41 | + create_table "solid_queue_job_batches", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t| |
| 42 | + t.bigint "parent_job_batch_id" |
| 43 | + t.text "on_finish_active_job" |
| 44 | + t.text "on_success_active_job" |
| 45 | + t.text "on_failure_active_job" |
| 46 | + t.datetime "finished_at" |
| 47 | + t.datetime "changed_at" |
| 48 | + t.datetime "last_changed_at" |
| 49 | + t.datetime "created_at", null: false |
| 50 | + t.datetime "updated_at", null: false |
| 51 | + t.index ["changed_at"], name: "index_solid_queue_job_batches_on_changed_at" |
| 52 | + t.index ["finished_at"], name: "index_solid_queue_job_batches_on_finished_at" |
| 53 | + t.index ["last_changed_at"], name: "index_solid_queue_job_batches_on_last_changed_at" |
| 54 | + t.index ["parent_job_batch_id"], name: "index_solid_queue_job_batches_on_parent_job_batch_id" |
| 55 | + end |
| 56 | + |
41 | 57 | create_table "solid_queue_jobs", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
|
42 | 58 | t.string "queue_name", null: false
|
43 | 59 | t.string "class_name", null: false
|
|
49 | 65 | t.string "concurrency_key"
|
50 | 66 | t.datetime "created_at", null: false
|
51 | 67 | t.datetime "updated_at", null: false
|
| 68 | + t.bigint "batch_id" |
52 | 69 | t.index ["active_job_id"], name: "index_solid_queue_jobs_on_active_job_id"
|
| 70 | + t.index ["batch_id"], name: "index_solid_queue_jobs_on_batch_id" |
53 | 71 | t.index ["class_name"], name: "index_solid_queue_jobs_on_class_name"
|
54 | 72 | t.index ["finished_at"], name: "index_solid_queue_jobs_on_finished_at"
|
55 | 73 | t.index ["queue_name", "finished_at"], name: "index_solid_queue_jobs_for_filtering"
|
|
135 | 153 | add_foreign_key "solid_queue_blocked_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
136 | 154 | add_foreign_key "solid_queue_claimed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
137 | 155 | add_foreign_key "solid_queue_failed_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
| 156 | + add_foreign_key "solid_queue_jobs", "solid_queue_job_batches", column: "batch_id", on_delete: :cascade |
138 | 157 | add_foreign_key "solid_queue_ready_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
139 | 158 | add_foreign_key "solid_queue_recurring_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
140 | 159 | add_foreign_key "solid_queue_scheduled_executions", "solid_queue_jobs", column: "job_id", on_delete: :cascade
|
|
0 commit comments