From a659ebc8c3d04e61bd7f850280f67bdb9dcb3dc4 Mon Sep 17 00:00:00 2001 From: Aaron Harper Date: Wed, 1 May 2024 14:06:05 -0400 Subject: [PATCH] Fix queue item score --- pkg/execution/state/redis_state/queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/execution/state/redis_state/queue.go b/pkg/execution/state/redis_state/queue.go index 37906b96c6..2774fffa37 100644 --- a/pkg/execution/state/redis_state/queue.go +++ b/pkg/execution/state/redis_state/queue.go @@ -621,7 +621,7 @@ func (q QueueItem) Score() int64 { return startAt - q.Data.GetPriorityFactor() } - return q.AtMS - q.Data.GetPriorityFactor() + return startAt - q.Data.GetPriorityFactor() } func (q QueueItem) MarshalBinary() ([]byte, error) {