go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-09-20 11:05:58 +08:00
Code Issues Projects Releases Wiki Activity

Minor comment fix

Browse Source
This commit is contained in:
Ken Hibino 2020-07-26 07:01:19 -07:00
parent a28f61f313
commit 92d77bbc6e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/asynqtest/asynqtest.go
View File

@ -173,7 +173,7 @@ func SeedEnqueuedQueue(tb testing.TB, r *redis.Client, msgs []*base.TaskMessage,
// SeedAllEnqueuedQueues initializes all of the specified queues with the given messages. // SeedAllEnqueuedQueues initializes all of the specified queues with the given messages.
// //
// enqueued map maps a queue name a list of messages. // enqueued maps a queue name to a list of messages.
func SeedAllEnqueuedQueues(tb testing.TB, r *redis.Client, enqueued map[string][]*base.TaskMessage) { func SeedAllEnqueuedQueues(tb testing.TB, r *redis.Client, enqueued map[string][]*base.TaskMessage) {
for q, msgs := range enqueued { for q, msgs := range enqueued {
SeedEnqueuedQueue(tb, r, msgs, q) SeedEnqueuedQueue(tb, r, msgs, q)