fix(processor): Drop mutex for ImmediatelyExportItems (#224)

ethpandaops · Oct 4, 2023 · f2c5a6a · f2c5a6a
1 parent 5b81903
commit f2c5a6a
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/pkg/processor/batch.go b/pkg/processor/batch.go
@@ -192,9 +192,6 @@ func (bvp *BatchItemProcessor[T]) ImmediatelyExportItems(ctx context.Context, it
 	_, span := observability.Tracer().Start(ctx, "BatchItemProcessor.ImmediatelyExportItems")
 	defer span.End()
 
-	bvp.batchMutex.Lock()
-	defer bvp.batchMutex.Unlock()
-
 	if l := len(items); l > 0 {
 		countItemsToExport := len(items)