diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index 40c5a5eb4..f3dbe9235 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -339,6 +339,8 @@ func (t *QueueManager) calculateDesiredShards() { numShards := int(math.Ceil(desiredShards)) if numShards > t.cfg.MaxShards { numShards = t.cfg.MaxShards + } else if numShards < 1 { + numShards = 1 } if numShards == t.numShards { return