diff options
Diffstat (limited to 'modules/queue/workerpool.go')
| -rw-r--r-- | modules/queue/workerpool.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/modules/queue/workerpool.go b/modules/queue/workerpool.go index 0176e2e0b2..653d0558c8 100644 --- a/modules/queue/workerpool.go +++ b/modules/queue/workerpool.go @@ -341,7 +341,7 @@ func (p *WorkerPool) FlushWithContext(ctx context.Context) error { func (p *WorkerPool) doWork(ctx context.Context) { delay := time.Millisecond * 300 - var data = make([]Data, 0, p.batchLength) + data := make([]Data, 0, p.batchLength) for { select { case <-ctx.Done(): |