asynq: task lease expired #393

New issue

Open

opened 2026-03-02 05:20:54 +03:00 by kerem · 2 comments

kerem commented

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

Owner

Originally created by @wenlng on GitHub (Dec 30, 2023).
Original GitHub issue: https://github.com/hibiken/asynq/issues/799

Originally assigned to: @hibiken on GitHub.

When dealing with a very long task, the lease will occasionally expire, resulting in the task being canceled before it is completed， context canceled

To Reproduce
taskInfo, err := asynqClient.Enqueue(
asynq.NewTask("SyncDataTask", payload),
asynq.Timeout(time.Second*3600), // The timeout period of the task is set to 1 hour
)

Expected behavior
The task takes about half an hour to complete, after several tests, in the process of processing occasionally occurs asynq: task lease expired, resulting in the task is terminated, hope the author pay attention to this problem, thank you!

Screenshots
...

Environment (please complete the following information):

OS: MacOS or Linux
Version of asynq package v0.24.1

Additional context
....

Originally created by @wenlng on GitHub (Dec 30, 2023). Original GitHub issue: https://github.com/hibiken/asynq/issues/799 Originally assigned to: @hibiken on GitHub. When dealing with a very long task, the lease will occasionally expire, resulting in the task being canceled before it is completed， context canceled **To Reproduce** taskInfo, err := asynqClient.Enqueue( asynq.NewTask("SyncDataTask", payload), asynq.Timeout(time.Second*3600), // The timeout period of the task is set to 1 hour ) **Expected behavior** The task takes about half an hour to complete, after several tests, in the process of processing occasionally occurs asynq: task lease expired, resulting in the task is terminated, hope the author pay attention to this problem, thank you! **Screenshots** ... **Environment (please complete the following information):** - OS: MacOS or Linux - Version of `asynq` package v0.24.1 **Additional context** ....

kerem added the

bug

label

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

kerem commented

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

Author

Owner

@alipeng commented on GitHub (Dec 31, 2023):

Maybe you should check your redis first. redis-cli info | grep memory_human. I also encountered the same problem. Finally, I checked and found that it was a redis problem. It's redis maxmemory-policy "volatile-lru"

@alipeng commented on GitHub (Dec 31, 2023): Maybe you should check your redis first. `redis-cli info | grep memory_human`. I also encountered the same problem. Finally, I checked and found that it was a redis problem. It's redis `maxmemory-policy` "volatile-lru"

kerem commented

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

Author

Owner

@justding commented on GitHub (Jan 24, 2024):

Maybe you should check your redis first. redis-cli info | grep memory_human. I also encountered the same problem. Finally, I checked and found that it was a redis problem. It's redis maxmemory-policy "volatile-lru"

in processor func exe() { msg, leaseExpirationTime, err := p.broker.Dequeue(qnames...)}

@justding commented on GitHub (Jan 24, 2024): > Maybe you should check your redis first. `redis-cli info | grep memory_human`. I also encountered the same problem. Finally, I checked and found that it was a redis problem. It's redis `maxmemory-policy` "volatile-lru" in processor func exe() { msg, leaseExpirationTime, err := p.broker.Dequeue(qnames...)}

kerem referenced this issue

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

[PR #1070] [MERGED] Feature: Add Headers Support to Tasks #1007

kerem referenced this issue

2026-03-07 22:06:57 +03:00

[GH-ISSUE #393] [FEATURE REQUEST] Add message headers #1187

kerem referenced this issue

2026-03-07 22:07:56 +03:00

[GH-ISSUE #497] [FEATURE REQUEST] Task header ability #1241

kerem referenced this issue

2026-03-07 22:14:18 +03:00

[PR #1070] [MERGED] Feature: Add Headers Support to Tasks #2016