[PR #162] [CLOSED] WIP: Fix Message forwarding #644

New issue

Closed

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

kerem commented

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

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/162
Author: @hibiken
Created: 6/7/2020
Status: ❌ Closed

Base: master ← Head: fix/check_and_schedule

📝 Commits (10+)

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
0ec4255 Update benchmark.sh to log at debug level
9b7b1bb Update benchmark.sh to print debug logs
d9161d6 Fix end-to-end benchmark to be deterministic
6b8a4ee Debug commit
8c6a21f WIP: Fix CheckAndEnqueue script to forward messages in chunks

📊 Changes

16 files changed (+574 additions, -100 deletions)

View changed files

📝 .travis.yml (+1 -0)
📝 .travis/benchcmp.sh (+5 -3)
📝 asynq.go (+14 -12)
📝 benchmark_test.go (+13 -2)
📝 heartbeat.go (+22 -0)
📝 internal/base/base.go (+1 -0)
📝 internal/rdb/inspect.go (+55 -3)
📝 internal/rdb/inspect_test.go (+215 -3)
📝 internal/rdb/rdb.go (+34 -55)
📝 internal/rdb/rdb_test.go (+91 -0)
📝 processor.go (+5 -7)
📝 processor_test.go (+5 -3)
📝 syncer.go (+2 -0)
➕ tools/asynq/cmd/pause.go (+47 -0)
📝 tools/asynq/cmd/stats.go (+18 -12)
➕ tools/asynq/cmd/unpause.go (+46 -0)

📄 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/162 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 6/7/2020 **Status:** ❌ Closed **Base:** `master` ← **Head:** `fix/check_and_schedule` --- ### 📝 Commits (10+) - [`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 - [`0ec4255`](https://github.com/hibiken/asynq/commit/0ec4255691fd4f851cbcc8d523f23eac48c69642) Update benchmark.sh to log at debug level - [`9b7b1bb`](https://github.com/hibiken/asynq/commit/9b7b1bbff6b930cb11f16eadaa22ff272ef1c3fd) Update benchmark.sh to print debug logs - [`d9161d6`](https://github.com/hibiken/asynq/commit/d9161d621f8a87bdb1f7da859b478f7c3d43ebd3) Fix end-to-end benchmark to be deterministic - [`6b8a4ee`](https://github.com/hibiken/asynq/commit/6b8a4eed5489aaa88beb45fe0bae3ba3c086fc8b) Debug commit - [`8c6a21f`](https://github.com/hibiken/asynq/commit/8c6a21ff59b2cd839358a82eef4cb44b5037d5fc) WIP: Fix CheckAndEnqueue script to forward messages in chunks ### 📊 Changes **16 files changed** (+574 additions, -100 deletions) <details> <summary>View changed files</summary> 📝 `.travis.yml` (+1 -0) 📝 `.travis/benchcmp.sh` (+5 -3) 📝 `asynq.go` (+14 -12) 📝 `benchmark_test.go` (+13 -2) 📝 `heartbeat.go` (+22 -0) 📝 `internal/base/base.go` (+1 -0) 📝 `internal/rdb/inspect.go` (+55 -3) 📝 `internal/rdb/inspect_test.go` (+215 -3) 📝 `internal/rdb/rdb.go` (+34 -55) 📝 `internal/rdb/rdb_test.go` (+91 -0) 📝 `processor.go` (+5 -7) 📝 `processor_test.go` (+5 -3) 📝 `syncer.go` (+2 -0) ➕ `tools/asynq/cmd/pause.go` (+47 -0) 📝 `tools/asynq/cmd/stats.go` (+18 -12) ➕ `tools/asynq/cmd/unpause.go` (+46 -0) </details> ### 📄 Description _No description provided_ --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>