[PR #47] [MERGED] Add multi-queue support with priority #566

New issue

Closed

opened 2026-03-02 05:54:04 +03:00 by kerem · 0 comments

kerem commented

2026-03-02 05:54:04 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/47
Author: @hibiken
Created: 1/8/2020
Status: ✅ Merged
Merged: 1/8/2020
Merged by: @hibiken

Base: master ← Head: feature/multiq

📝 Commits (10+)

cdc6e52 Add Queue option to allow user to specify queue from client
48572dd Add Queues field to Config
8e79be6 Update comment
889a35a Update CheckAndEnqueue to enqueue tasks to specified queue
79a2205 Delete stale code
d7ae925 Change RDB.Dequeue to query multiple queues
25a9373 Update processor to query queues based on priority
fb66f09 [ci skip] Normalize queue priority numbers
d5d4114 [ci skip] Upgrade github.com/google/go-cmp to v0.4.0
25b359a [ci skip] Update changelog

📊 Changes

16 files changed (+551 additions, -181 deletions)

View changed files

📝 CHANGELOG.md (+2 -0)
📝 background.go (+60 -1)
📝 background_test.go (+81 -0)
📝 client.go (+19 -4)
📝 client_test.go (+76 -28)
📝 go.mod (+1 -1)
📝 go.sum (+4 -2)
📝 internal/asynqtest/asynqtest.go (+19 -7)
📝 internal/base/base.go (+16 -8)
📝 internal/base/base_test.go (+16 -0)
📝 internal/rdb/inspect_test.go (+4 -41)
📝 internal/rdb/rdb.go (+44 -58)
📝 internal/rdb/rdb_test.go (+121 -20)
📝 processor.go (+43 -4)
📝 processor_test.go (+44 -6)
📝 scheduler_test.go (+1 -1)

📄 Description

Closes #20

_{🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.}

## 📋 Pull Request Information **Original PR:** https://github.com/hibiken/asynq/pull/47 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 1/8/2020 **Status:** ✅ Merged **Merged:** 1/8/2020 **Merged by:** [@hibiken](https://github.com/hibiken) **Base:** `master` ← **Head:** `feature/multiq` --- ### 📝 Commits (10+) - [`cdc6e52`](https://github.com/hibiken/asynq/commit/cdc6e520c4cf2842823b42b44d64ad095a6e9b0d) Add Queue option to allow user to specify queue from client - [`48572dd`](https://github.com/hibiken/asynq/commit/48572dd433f4baad0f28ba4dce441c7508459e8e) Add Queues field to Config - [`8e79be6`](https://github.com/hibiken/asynq/commit/8e79be6f5b72eb40cccab075012fc3801b434b86) Update comment - [`889a35a`](https://github.com/hibiken/asynq/commit/889a35af97f58fe9b516342219aaeb9d4214beb8) Update CheckAndEnqueue to enqueue tasks to specified queue - [`79a2205`](https://github.com/hibiken/asynq/commit/79a2205b1d18d995650d8119468f159669163752) Delete stale code - [`d7ae925`](https://github.com/hibiken/asynq/commit/d7ae925b399b604a8d4f0814e1b6d37cc171051c) Change RDB.Dequeue to query multiple queues - [`25a9373`](https://github.com/hibiken/asynq/commit/25a93737df8a887d9c65c42399d6e9945ba96563) Update processor to query queues based on priority - [`fb66f09`](https://github.com/hibiken/asynq/commit/fb66f0977ac215218ded65f7dc9643d7c86e41a7) [ci skip] Normalize queue priority numbers - [`d5d4114`](https://github.com/hibiken/asynq/commit/d5d411424053266c5e50745792de511b0998be5d) [ci skip] Upgrade github.com/google/go-cmp to v0.4.0 - [`25b359a`](https://github.com/hibiken/asynq/commit/25b359a795086576e19a1ea3871c3b8fcfc943b3) [ci skip] Update changelog ### 📊 Changes **16 files changed** (+551 additions, -181 deletions) <details> <summary>View changed files</summary> 📝 `CHANGELOG.md` (+2 -0) 📝 `background.go` (+60 -1) 📝 `background_test.go` (+81 -0) 📝 `client.go` (+19 -4) 📝 `client_test.go` (+76 -28) 📝 `go.mod` (+1 -1) 📝 `go.sum` (+4 -2) 📝 `internal/asynqtest/asynqtest.go` (+19 -7) 📝 `internal/base/base.go` (+16 -8) 📝 `internal/base/base_test.go` (+16 -0) 📝 `internal/rdb/inspect_test.go` (+4 -41) 📝 `internal/rdb/rdb.go` (+44 -58) 📝 `internal/rdb/rdb_test.go` (+121 -20) 📝 `processor.go` (+43 -4) 📝 `processor_test.go` (+44 -6) 📝 `scheduler_test.go` (+1 -1) </details> ### 📄 Description Closes #20 --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>