[PR #36] [CLOSED] Priority queues #562

New issue

Closed

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

kerem commented

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

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/36
Author: @hibiken
Created: 1/2/2020
Status: ❌ Closed

Base: master ← Head: feature/priority

📝 Commits (6)

31a18d7 Add Priority type in base package
2e95166 Remove Queue field and Priority field to base.TaskMessage
eb191c0 Export (High|Low)PriorityQueue constant from base pkg
5c42bdc Change (*RDB).Dequeue to query multiple queues in order
6de80f9 Change dequeue method to use lua script
fc5b65d Add a function to return a list of queues to query

📊 Changes

10 files changed (+335 additions, -84 deletions)

View changed files

📝 client.go (+5 -5)
📝 client_test.go (+20 -20)
📝 internal/asynqtest/asynqtest.go (+29 -5)
📝 internal/base/base.go (+31 -10)
📝 internal/base/base_test.go (+18 -0)
📝 internal/rdb/inspect_test.go (+4 -4)
📝 internal/rdb/rdb.go (+31 -10)
📝 internal/rdb/rdb_test.go (+125 -19)
📝 processor.go (+50 -9)
📝 processor_test.go (+22 -2)

📄 Description

No description provided

_{🔄 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/36 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 1/2/2020 **Status:** ❌ Closed **Base:** `master` ← **Head:** `feature/priority` --- ### 📝 Commits (6) - [`31a18d7`](https://github.com/hibiken/asynq/commit/31a18d783e6138152016851a637cdf798f234c99) Add Priority type in base package - [`2e95166`](https://github.com/hibiken/asynq/commit/2e95166f397dd3b68f1f74ddb402bf91abe54a25) Remove Queue field and Priority field to base.TaskMessage - [`eb191c0`](https://github.com/hibiken/asynq/commit/eb191c07d1e574546e376b165fb24baf650d520e) Export (High|Low)PriorityQueue constant from base pkg - [`5c42bdc`](https://github.com/hibiken/asynq/commit/5c42bdc4c4f2a8d95a2e8910f639b28f186bfa6f) Change (*RDB).Dequeue to query multiple queues in order - [`6de80f9`](https://github.com/hibiken/asynq/commit/6de80f9f0482bf3efc286b07a350a00fe7c30976) Change dequeue method to use lua script - [`fc5b65d`](https://github.com/hibiken/asynq/commit/fc5b65ddaed73fda6ee472b614de957433fd4d11) Add a function to return a list of queues to query ### 📊 Changes **10 files changed** (+335 additions, -84 deletions) <details> <summary>View changed files</summary> 📝 `client.go` (+5 -5) 📝 `client_test.go` (+20 -20) 📝 `internal/asynqtest/asynqtest.go` (+29 -5) 📝 `internal/base/base.go` (+31 -10) 📝 `internal/base/base_test.go` (+18 -0) 📝 `internal/rdb/inspect_test.go` (+4 -4) 📝 `internal/rdb/rdb.go` (+31 -10) 📝 `internal/rdb/rdb_test.go` (+125 -19) 📝 `processor.go` (+50 -9) 📝 `processor_test.go` (+22 -2) </details> ### 📄 Description _No description provided_ --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>