[PR #81] [MERGED] Add support for cancelation and timeout #1603

Closed
opened 2026-03-07 22:11:31 +03:00 by kerem · 0 comments
Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/81
Author: @hibiken
Created: 2/13/2020
Status: Merged
Merged: 2/13/2020
Merged by: @hibiken

Base: masterHead: next


📝 Commits (9)

  • bc97ae1 Change Handler interface to take context.Context
  • 5780182 Send cancellation signal to all in-progress handlers on shutdown
  • 379ae88 Allow user to specify timeout per task
  • a4ebd4d Update docs for context and timeout
  • 2e07266 Add redis pubsub subscriber for cancelation
  • c41e666 Add cancel command to asynqmon cli
  • d757b62 [ci skip] Update readme and changelog
  • d22253e Use int as priority value type.
  • e3da772 [ci skip] Update changelog

📊 Changes

24 files changed (+464 additions, -106 deletions)

View changed files

📝 CHANGELOG.md (+10 -0)
📝 README.md (+6 -6)
📝 background.go (+28 -14)
📝 background_test.go (+21 -20)
📝 benchmark_test.go (+5 -4)
📝 client.go (+19 -6)
📝 client_test.go (+27 -0)
📝 doc.go (+1 -1)
📝 heartbeat_test.go (+2 -2)
📝 internal/base/base.go (+57 -2)
📝 internal/base/base_test.go (+1 -1)
📝 internal/rdb/inspect.go (+2 -2)
📝 internal/rdb/inspect_test.go (+12 -12)
📝 internal/rdb/rdb.go (+16 -0)
📝 internal/rdb/rdb_test.go (+1 -1)
📝 processor.go (+40 -13)
📝 processor_test.go (+20 -15)
📝 scheduler.go (+1 -1)
subscriber.go (+58 -0)
subscriber_test.go (+57 -0)

...and 4 more files

📄 Description

Closes #69


🔄 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/81 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 2/13/2020 **Status:** ✅ Merged **Merged:** 2/13/2020 **Merged by:** [@hibiken](https://github.com/hibiken) **Base:** `master` ← **Head:** `next` --- ### 📝 Commits (9) - [`bc97ae1`](https://github.com/hibiken/asynq/commit/bc97ae14e99df1919085e10316f3611c4133a55e) Change Handler interface to take context.Context - [`5780182`](https://github.com/hibiken/asynq/commit/578018234db58bcb7520fa437c81cbf6b4b2c324) Send cancellation signal to all in-progress handlers on shutdown - [`379ae88`](https://github.com/hibiken/asynq/commit/379ae88cd323995cd7f1f7438344f7a2bce4a551) Allow user to specify timeout per task - [`a4ebd4d`](https://github.com/hibiken/asynq/commit/a4ebd4d76b4587dbe79438ed8f7792639da4b16e) Update docs for context and timeout - [`2e07266`](https://github.com/hibiken/asynq/commit/2e07266ee1be5fad76dd20842b68f5721ed9e8ee) Add redis pubsub subscriber for cancelation - [`c41e666`](https://github.com/hibiken/asynq/commit/c41e6666438868a2dea38afbc8e82df398ca5d5b) Add cancel command to asynqmon cli - [`d757b62`](https://github.com/hibiken/asynq/commit/d757b6296f443a2aa0b112f552ca598d2e91dc0c) [ci skip] Update readme and changelog - [`d22253e`](https://github.com/hibiken/asynq/commit/d22253ebf9738eac848038f18533af5c4ea59bf3) Use int as priority value type. - [`e3da772`](https://github.com/hibiken/asynq/commit/e3da772426aa7a4b66b07b4b0e457a00b9916dd2) [ci skip] Update changelog ### 📊 Changes **24 files changed** (+464 additions, -106 deletions) <details> <summary>View changed files</summary> 📝 `CHANGELOG.md` (+10 -0) 📝 `README.md` (+6 -6) 📝 `background.go` (+28 -14) 📝 `background_test.go` (+21 -20) 📝 `benchmark_test.go` (+5 -4) 📝 `client.go` (+19 -6) 📝 `client_test.go` (+27 -0) 📝 `doc.go` (+1 -1) 📝 `heartbeat_test.go` (+2 -2) 📝 `internal/base/base.go` (+57 -2) 📝 `internal/base/base_test.go` (+1 -1) 📝 `internal/rdb/inspect.go` (+2 -2) 📝 `internal/rdb/inspect_test.go` (+12 -12) 📝 `internal/rdb/rdb.go` (+16 -0) 📝 `internal/rdb/rdb_test.go` (+1 -1) 📝 `processor.go` (+40 -13) 📝 `processor_test.go` (+20 -15) 📝 `scheduler.go` (+1 -1) ➕ `subscriber.go` (+58 -0) ➕ `subscriber_test.go` (+57 -0) _...and 4 more files_ </details> ### 📄 Description Closes #69 --- <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:31 +03:00
Sign in to join this conversation.
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#1603
No description provided.