diff --git a/modules/queue/queue_disk_channel.go b/modules/queue/queue_disk_channel.go index e2ee0bda56..2098353879 100644 --- a/modules/queue/queue_disk_channel.go +++ b/modules/queue/queue_disk_channel.go @@ -59,7 +59,7 @@ func NewPersistableChannelQueue(handle HandlerFunc, cfg, exemplar interface{}) ( return nil, err } - // the level backend only needs temporary workrers to catch up with the previously dropped work + // the level backend only needs temporary workers to catch up with the previously dropped work levelCfg := LevelQueueConfiguration{ DataDir: config.DataDir, QueueLength: config.QueueLength,