Found while reviewing PR #69 with the SuperJoe crew, filed as out-of-scope there.
RedisTaskBackend.enqueue() stores queue_name in the task hash, and nothing reads it: the acquire and mover scripts read data and score, the reaper checks existence only, and every reader takes the queue from the payload's task.queue_name or from the key it found the id under. It is one field written per enqueue with no consumer.
Either drop it, or make a reader use it instead of carrying the queue name in the payload as well.
Reference: threadmill/backends/redis.py, the enqueue hash mapping.
Found while reviewing PR #69 with the SuperJoe crew, filed as out-of-scope there.
RedisTaskBackend.enqueue()storesqueue_namein the task hash, and nothing reads it: the acquire and mover scripts readdataandscore, the reaper checks existence only, and every reader takes the queue from the payload'stask.queue_nameor from the key it found the id under. It is one field written per enqueue with no consumer.Either drop it, or make a reader use it instead of carrying the queue name in the payload as well.
Reference:
threadmill/backends/redis.py, the enqueue hash mapping.