pass equal amount of ids as keys in xreadgroup

Author: Derk Schooltink

backend/valkey/queue.go

@@ -169,8 +169,13 @@ func (q *taskQueue[T]) Dequeue(ctx context.Context, client valkey.Client, queues
 		streamKeys = append(streamKeys, keyInfo.StreamKey)
 	}
 
+	ids := make([]string, len(streamKeys))
+	for i := range ids {
+		ids[i] = ">"
+	}
+
 	// Try to dequeue from all given queues
-	cmd := client.B().Xreadgroup().Group(q.groupName, q.workerName).Streams().Key(streamKeys...).Id(">")
+	cmd := client.B().Xreadgroup().Group(q.groupName, q.workerName).Streams().Key(streamKeys...).Id(ids...)
 	results, err := client.Do(ctx, cmd.Build()).AsXRead()
 	if err != nil {
 		// Check if error is due to no data available (nil response)