Skip to content

Commit f85e196

Browse files
author
Derk Schooltink
committed
avoid shadowing keys name
1 parent f4217bf commit f85e196

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

backend/valkey/queue.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,9 +134,8 @@ func (q *taskQueue[T]) Enqueue(ctx context.Context, client valkey.Client, queue
134134
return err
135135
}
136136

137-
keys := q.Keys(queue)
138-
139-
if err := enqueueCmd.Exec(ctx, client, []string{q.queueSetKey, keys.SetKey, keys.StreamKey}, []string{q.groupName, id, string(ds)}).Error(); err != nil {
137+
queueStreamInfo := q.Keys(queue)
138+
if err := enqueueCmd.Exec(ctx, client, []string{q.queueSetKey, queueStreamInfo.SetKey, queueStreamInfo.StreamKey}, []string{q.groupName, id, string(ds)}).Error(); err != nil {
140139
return fmt.Errorf("enqueueing task: %w", err)
141140
}
142141

0 commit comments

Comments
 (0)