Skip to content

Commit

Permalink
[chore] Simplify condition in NewBaseExporter (#12249)
Browse files Browse the repository at this point in the history
  • Loading branch information
dmitryax authored Feb 2, 2025
1 parent 466c497 commit 10f11f7
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions exporter/exporterhelper/internal/base_exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,8 +100,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe
be.ConsumerOptions = append(be.ConsumerOptions, consumer.WithCapabilities(consumer.Capabilities{MutatesData: true}))
}

if !usePullingBasedExporterQueueBatcher.IsEnabled() && be.batcherCfg.Enabled ||
usePullingBasedExporterQueueBatcher.IsEnabled() && be.batcherCfg.Enabled && !be.queueCfg.Enabled {
if be.batcherCfg.Enabled && !(usePullingBasedExporterQueueBatcher.IsEnabled() && be.queueCfg.Enabled) {
concurrencyLimit := int64(0)
if be.queueCfg.Enabled {
concurrencyLimit = int64(be.queueCfg.NumConsumers)
Expand Down

0 comments on commit 10f11f7

Please sign in to comment.