mirror of
https://github.com/bitmagnet-io/bitmagnet.git
synced 2025-12-28 06:34:17 +00:00
Fix duplicate key error (#338)
This commit is contained in:
parent
6ec9047527
commit
f1c866d692
19
migrations/00019_queue_fix_duplicate_key.sql
Normal file
19
migrations/00019_queue_fix_duplicate_key.sql
Normal file
@ -0,0 +1,19 @@
|
||||
-- +goose Up
|
||||
-- +goose StatementBegin
|
||||
|
||||
DELETE FROM queue_jobs qj WHERE qj.status = 'retry' AND EXISTS (SELECT * FROM queue_jobs qj2 WHERE qj2.status = 'pending' AND qj2.fingerprint = qj.fingerprint);
|
||||
|
||||
DROP INDEX IF EXISTS queue_jobs_fingerprint_status_idx;
|
||||
|
||||
CREATE UNIQUE INDEX queue_jobs_fingerprint_idx ON queue_jobs (fingerprint) WHERE status IN ('pending', 'retry');
|
||||
|
||||
-- +goose StatementEnd
|
||||
|
||||
-- +goose Down
|
||||
-- +goose StatementBegin
|
||||
|
||||
DROP INDEX IF EXISTS queue_jobs_fingerprint_idx;
|
||||
|
||||
CREATE UNIQUE INDEX ON queue_jobs (fingerprint, status) WHERE status IN ('pending', 'retry');
|
||||
|
||||
-- +goose StatementEnd
|
||||
Loading…
Reference in New Issue
Block a user