2022-05-12-backfillqueue-remove-time-end.go 308 B

12345678910111213141516
  1. package upgrades
  2. import (
  3. "database/sql"
  4. )
  5. func init() {
  6. upgrades[45] = upgrade{"Add dispatch time to backfill queue", func(tx *sql.Tx, ctx context) error {
  7. // First, add dispatch_time TIMESTAMP column
  8. _, err := tx.Exec(`
  9. ALTER TABLE backfill_queue
  10. DROP COLUMN time_end
  11. `)
  12. return err
  13. }}
  14. }