diff options
Diffstat (limited to 'modules/queue/queue_redis.go')
| -rw-r--r-- | modules/queue/queue_redis.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/modules/queue/queue_redis.go b/modules/queue/queue_redis.go index 8a395cd5aa..4e05ddd17e 100644 --- a/modules/queue/queue_redis.go +++ b/modules/queue/queue_redis.go @@ -121,7 +121,7 @@ func (fifo *RedisByteFIFO) PushFunc(data []byte, fn func() error) error { // Pop pops data from the start of the fifo func (fifo *RedisByteFIFO) Pop() ([]byte, error) { data, err := fifo.client.LPop(fifo.queueName).Bytes() - if err != nil && err == redis.Nil { + if err == nil || err == redis.Nil { return data, nil } return data, err |