From 12225b2dff3afd2abd956246545da98b5d18084e Mon Sep 17 00:00:00 2001 From: Jade Guiton Date: Fri, 31 Jan 2025 16:46:15 +0100 Subject: [PATCH] Propagate Context in DisabledBatcher --- exporter/internal/queue/disabled_batcher.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/exporter/internal/queue/disabled_batcher.go b/exporter/internal/queue/disabled_batcher.go index be89f58e011..5f29e022bb6 100644 --- a/exporter/internal/queue/disabled_batcher.go +++ b/exporter/internal/queue/disabled_batcher.go @@ -29,13 +29,13 @@ func (qb *DisabledBatcher) Start(_ context.Context, _ component.Host) error { go func() { defer qb.stopWG.Done() for { - idx, _, req, ok := qb.queue.Read(context.Background()) + idx, ctx, req, ok := qb.queue.Read(context.Background()) if !ok { return } qb.flush(batch{ req: req, - ctx: context.Background(), + ctx: ctx, idxList: []uint64{idx}, }) }