diff options
Diffstat (limited to 'modules/queue/workerqueue.go')
| -rw-r--r-- | modules/queue/workerqueue.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/modules/queue/workerqueue.go b/modules/queue/workerqueue.go index e0d5183bd9..b28fd88027 100644 --- a/modules/queue/workerqueue.go +++ b/modules/queue/workerqueue.go @@ -93,7 +93,7 @@ func (q *WorkerPoolQueue[T]) GetQueueItemNumber() int { func (q *WorkerPoolQueue[T]) FlushWithContext(ctx context.Context, timeout time.Duration) (err error) { if q.isBaseQueueDummy() { - return + return nil } log.Debug("Try to flush queue %q with timeout %v", q.GetName(), timeout) |