diff --git a/threadmill/backends/redis.py b/threadmill/backends/redis.py index 136ebfa..96f3165 100644 --- a/threadmill/backends/redis.py +++ b/threadmill/backends/redis.py @@ -267,7 +267,6 @@ def enqueue( mapping={ "data": serialized, "score": str(score), - "queue_name": task.queue_name, }, ) pipe.expire(task_key, task_data_ttl)