[PR #159] [MERGED] Add Feature to Pause Queue #1654

New issue

Closed

opened 2026-03-07 22:11:45 +03:00 by kerem · 0 comments

kerem commented

2026-03-07 22:11:45 +03:00

Owner

📋 Pull Request Information

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

Base: master ← Head: feature/pause

📝 Commits (7)

0893efc Add Pause and Unpause methods to rdb
00a9053 Update Dequeue operation to skip paused queues
7d53c79 Add pause and unpause command to CLI
b97ef4a Update stats command to show queue paused status
153a795 Fix data race in test
15bc2e4 Limit the number of tasks moved by CheckAndEnqueue to prevent a long
1189097 Add benchmark test to verify client enqueue performance while server is

📊 Changes

17 files changed (+623 additions, -127 deletions)

View changed files

📝 .travis.yml (+1 -0)
📝 .travis/benchcmp.sh (+5 -2)
📝 benchmark_test.go (+72 -4)
📝 internal/base/base.go (+2 -1)
📝 internal/rdb/inspect.go (+62 -3)
📝 internal/rdb/inspect_test.go (+212 -6)
📝 internal/rdb/rdb.go (+51 -67)
📝 internal/rdb/rdb_test.go (+92 -6)
📝 internal/testbroker/testbroker.go (+1 -1)
📝 processor.go (+6 -8)
📝 processor_test.go (+5 -3)
📝 scheduler.go (+1 -10)
📝 scheduler_test.go (+0 -1)
📝 server.go (+2 -3)
➕ tools/asynq/cmd/pause.go (+47 -0)
📝 tools/asynq/cmd/stats.go (+18 -12)
➕ tools/asynq/cmd/unpause.go (+46 -0)

📄 Description

Closes #125

_{🔄 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/159 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 6/5/2020 **Status:** ✅ Merged **Merged:** 6/8/2020 **Merged by:** [@hibiken](https://github.com/hibiken) **Base:** `master` ← **Head:** `feature/pause` --- ### 📝 Commits (7) - [`0893efc`](https://github.com/hibiken/asynq/commit/0893efc18e984931a6469b3f239bfcee16c4091d) Add Pause and Unpause methods to rdb - [`00a9053`](https://github.com/hibiken/asynq/commit/00a90532acc8d4c99b5d562eb88b00e2424c31c8) Update Dequeue operation to skip paused queues - [`7d53c79`](https://github.com/hibiken/asynq/commit/7d53c7946f38fbfc45ac47d914dd095464cfcde5) Add pause and unpause command to CLI - [`b97ef4a`](https://github.com/hibiken/asynq/commit/b97ef4a3f362b6d869faea166b704cef5e0129fe) Update stats command to show queue paused status - [`153a795`](https://github.com/hibiken/asynq/commit/153a7959036c143e6fe30a1071b90a0b72301fe5) Fix data race in test - [`15bc2e4`](https://github.com/hibiken/asynq/commit/15bc2e4295f87458717eff0473ae747d57d9b776) Limit the number of tasks moved by CheckAndEnqueue to prevent a long - [`1189097`](https://github.com/hibiken/asynq/commit/1189097d3c7eabbf6abff373743a4be3872e9db3) Add benchmark test to verify client enqueue performance while server is ### 📊 Changes **17 files changed** (+623 additions, -127 deletions) <details> <summary>View changed files</summary> 📝 `.travis.yml` (+1 -0) 📝 `.travis/benchcmp.sh` (+5 -2) 📝 `benchmark_test.go` (+72 -4) 📝 `internal/base/base.go` (+2 -1) 📝 `internal/rdb/inspect.go` (+62 -3) 📝 `internal/rdb/inspect_test.go` (+212 -6) 📝 `internal/rdb/rdb.go` (+51 -67) 📝 `internal/rdb/rdb_test.go` (+92 -6) 📝 `internal/testbroker/testbroker.go` (+1 -1) 📝 `processor.go` (+6 -8) 📝 `processor_test.go` (+5 -3) 📝 `scheduler.go` (+1 -10) 📝 `scheduler_test.go` (+0 -1) 📝 `server.go` (+2 -3) ➕ `tools/asynq/cmd/pause.go` (+47 -0) 📝 `tools/asynq/cmd/stats.go` (+18 -12) ➕ `tools/asynq/cmd/unpause.go` (+46 -0) </details> ### 📄 Description Closes #125 --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>

kerem

2026-03-07 22:11:45 +03:00

closed this issue
added the
pull-request
label

No milestone

No project

No assignees

1 participant

Notifications

Due date

The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference

starred/asynq#1654

No description provided.

Rows
Columns