Skip to content

Commit

Permalink
fix vet
Browse files Browse the repository at this point in the history
  • Loading branch information
lunny committed Mar 1, 2019
1 parent e17e3e5 commit 5ffaa9b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion modules/task/queue_redis.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ func NewRedisQueue(addrs string, password string, dbIdx int) (*RedisQueue, error
return &queue, nil
}

// Run starts to run the queue
func (r *RedisQueue) Run() error {
for {
bs, err := r.client.LPop(r.queueName).Bytes()
Expand All @@ -106,7 +107,6 @@ func (r *RedisQueue) Run() error {

time.Sleep(time.Millisecond * 100)
}
return nil
}

// Push implements Queue
Expand Down

0 comments on commit 5ffaa9b

Please sign in to comment.