[PR #1088] fix: queue cleanup #1012

New issue

Open

opened 2026-03-02 06:28:50 +03:00 by kerem · 0 comments

kerem commented

2026-03-02 06:28:50 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/1088
Author: @arttor
Created: 12/2/2025
Status: 🔄 Open

Base: master ← Head: bugfix/inspector-queue-delete

📝 Commits (1)

efb6c94 fix: queue cleanup

📊 Changes

1 file changed (+29 additions, -3 deletions)

View changed files

📝 internal/rdb/inspect.go (+29 -3)

📄 Description

Closes #508

Currently, not all queue stuctures from inspector.QueueStats are removed in inspector.RemoveQueue. PR fixing it by removing the following missing resources:

completed messages and queue
failed/processed message counters
paused queue flag

_{🔄 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/1088 **Author:** [@arttor](https://github.com/arttor) **Created:** 12/2/2025 **Status:** 🔄 Open **Base:** `master` ← **Head:** `bugfix/inspector-queue-delete` --- ### 📝 Commits (1) - [`efb6c94`](https://github.com/hibiken/asynq/commit/efb6c940385f292514ec3d837fe64fb2c1bc5e50) fix: queue cleanup ### 📊 Changes **1 file changed** (+29 additions, -3 deletions) <details> <summary>View changed files</summary> 📝 `internal/rdb/inspect.go` (+29 -3) </details> ### 📄 Description Closes #508 Currently, not all queue stuctures from [`inspector.QueueStats`](https://github.com/hibiken/asynq/blob/ff887e1f899739ac5c76a5c80db668ec9e7d0507/internal/rdb/inspect.go#L140C15-L140C27) are removed in [`inspector.RemoveQueue`](https://github.com/hibiken/asynq/blob/ff887e1f899739ac5c76a5c80db668ec9e7d0507/internal/rdb/inspect.go#L1886). PR fixing it by removing the following missing resources: - completed messages and queue - failed/processed message counters - paused queue flag --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>