-
Notifications
You must be signed in to change notification settings - Fork 2
Open
Description
Using an approximate TTL can have issues; for example, a task may have been delayed, so it's still in queue but expired from redis. This would allow enqueueing it twice.
I'd like to propose adding keys to the store, and have the after_return and on_failure remove them from the store.
This makes sure we never have queued tasks that are missing from the redis backend uniqueness store. It also simplifies code quite a bit.
If having stale entries is a strong concern, acks_late can be enforced for unique tasks. However, stale entries should not be an issue, because we only cancel the old entry, so this flow would mean that we just cancel-or-noop the old entry.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels