[PR #576] Add TaskStateProber to get task state changed events #1795

New issue

Open

opened 2026-03-07 22:13:15 +03:00 by kerem · 0 comments

kerem commented

2026-03-07 22:13:15 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/576
Author: @mindon
Created: 11/21/2022
Status: 🔄 Open

Base: master ← Head: master

📝 Commits (10+)

db74324 Add TaskStateProber to get task state changed events
a247371 fix Result lack of key issue
d121033 Merge branch 'hibiken:master' into master
82f92d5 Merge branch 'hibiken:master' into master
0fac5fa Merge branch 'hibiken:master' into master
17cebdf Merge branch 'hibiken:master' into master
8c933d7 Merge branch 'hibiken:master' into master
8c0d758 Merge branch 'hibiken:master' into master
1fe0d81 fix: avoid retry if MaxRetry zero
8701305 Merge branch 'hibiken:master' into master

📊 Changes

5 files changed (+174 additions, -6 deletions)

View changed files

📝 client.go (+5 -0)
📝 internal/base/base.go (+8 -0)
📝 internal/rdb/rdb.go (+95 -5)
📝 processor.go (+7 -1)
📝 server.go (+59 -0)

📄 Description

(server | client).SetTaskStateProber(asynq.TaskStateProber{
  // Probers to specify what kind of state or data wanted, default = {*: task}
  // {state = pending | retry | compeleted | archieved | * : data-key = next | task | result }
  // Probers: map[string]string{} 

  // Handler process the state changed event
  Handler: func(out map[string]interface{}) {
    // default out contains {state, task: asynq.TaskInfo}
  },
})

_{🔄 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/576 **Author:** [@mindon](https://github.com/mindon) **Created:** 11/21/2022 **Status:** 🔄 Open **Base:** `master` ← **Head:** `master` --- ### 📝 Commits (10+) - [`db74324`](https://github.com/hibiken/asynq/commit/db743245357ed59df4cbb53a5feab69552c6a581) Add TaskStateProber to get task state changed events - [`a247371`](https://github.com/hibiken/asynq/commit/a2473713666079db55e76f5ea62608deba0943e1) fix Result lack of key issue - [`d121033`](https://github.com/hibiken/asynq/commit/d121033c37e2999464d738ddb16f404e16780fdc) Merge branch 'hibiken:master' into master - [`82f92d5`](https://github.com/hibiken/asynq/commit/82f92d53e4eb274c432b93f90123a29017fd52b9) Merge branch 'hibiken:master' into master - [`0fac5fa`](https://github.com/hibiken/asynq/commit/0fac5fa5a883f8c336b4be65a12fd8a6a6566a99) Merge branch 'hibiken:master' into master - [`17cebdf`](https://github.com/hibiken/asynq/commit/17cebdf149396cf193d7de08b224141255866bcb) Merge branch 'hibiken:master' into master - [`8c933d7`](https://github.com/hibiken/asynq/commit/8c933d7cd88729ff17896e3d99ec9f11b7a45732) Merge branch 'hibiken:master' into master - [`8c0d758`](https://github.com/hibiken/asynq/commit/8c0d758eef5612f11dde3ae0db844153e7f561ec) Merge branch 'hibiken:master' into master - [`1fe0d81`](https://github.com/hibiken/asynq/commit/1fe0d8154497298f24f61b9ae281e44e8b3b2b8e) fix: avoid retry if MaxRetry zero - [`8701305`](https://github.com/hibiken/asynq/commit/870130582dfee2aa9dea058b2235f2368bd6f30e) Merge branch 'hibiken:master' into master ### 📊 Changes **5 files changed** (+174 additions, -6 deletions) <details> <summary>View changed files</summary> 📝 `client.go` (+5 -0) 📝 `internal/base/base.go` (+8 -0) 📝 `internal/rdb/rdb.go` (+95 -5) 📝 `processor.go` (+7 -1) 📝 `server.go` (+59 -0) </details> ### 📄 Description ```golang (server | client).SetTaskStateProber(asynq.TaskStateProber{ // Probers to specify what kind of state or data wanted, default = {*: task} // {state = pending | retry | compeleted | archieved | * : data-key = next | task | result } // Probers: map[string]string{} // Handler process the state changed event Handler: func(out map[string]interface{}) { // default out contains {state, task: asynq.TaskInfo} }, }) ``` --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>

kerem added the

pull-request

label

2026-03-07 22:13:15 +03:00

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#1795

No description provided.

Rows
Columns