diff --git a/service/src/main/resources/lua/repair_queue_metadata.lua b/service/src/main/resources/lua/repair_queue_metadata.lua index 2b3a7e6ae..29d850427 100644 --- a/service/src/main/resources/lua/repair_queue_metadata.lua +++ b/service/src/main/resources/lua/repair_queue_metadata.lua @@ -6,7 +6,7 @@ local lastMessageId = tonumber(redis.call("ZRANGE", queueKey, -1, -1, "WITHSCOR if firstMessageId and lastMessageId then for messageId = firstMessageId,lastMessageId do - if redis.call("ZRANGEBYSCORE", queueKey, messageId, messageId) then + if next(redis.call("ZRANGEBYSCORE", queueKey, messageId, messageId)) then -- This message actually exists, and its GUID may be pointing to the wrong ID local guid = redis.call("HGET", queueMetadataKey, messageId .. "guid") redis.call("HSET", queueMetadataKey, guid, messageId)