Skip to content

Commit

Permalink
[chore] Remove duplicate options apply during export initialization (#…
Browse files Browse the repository at this point in the history
…11992)

Signed-off-by: Bogdan Drutu <[email protected]>
  • Loading branch information
bogdandrutu authored Jan 3, 2025
1 parent a7f1a2b commit 789cfb8
Showing 1 changed file with 0 additions and 7 deletions.
7 changes: 0 additions & 7 deletions exporter/exporterhelper/internal/base_exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,9 +99,6 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe
},
be.queueCfg)
be.QueueSender = NewQueueSender(q, be.Set, be.queueCfg.NumConsumers, be.ExportFailureMessage, be.Obsrep, be.BatcherCfg)
for _, op := range options {
err = multierr.Append(err, op(be))
}
}

if !usePullingBasedExporterQueueBatcher.IsEnabled() && be.BatcherCfg.Enabled ||
Expand All @@ -110,10 +107,6 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe
be.BatchSender = bs
}

if err != nil {
return nil, err
}

be.connectSenders()

if bs, ok := be.BatchSender.(*BatchSender); ok {
Expand Down

0 comments on commit 789cfb8

Please sign in to comment.