From 030d3823b997721111c14588960aa7136dc8d0e2 Mon Sep 17 00:00:00 2001
From: Aliaksandr Valialkin <valyala@victoriametrics.com>
Date: Sun, 19 May 2024 21:27:53 +0200
Subject: [PATCH] wip

---
 lib/logstorage/pipe_extract.go | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/lib/logstorage/pipe_extract.go b/lib/logstorage/pipe_extract.go
index 67850946f..7f2bee69d 100644
--- a/lib/logstorage/pipe_extract.go
+++ b/lib/logstorage/pipe_extract.go
@@ -60,7 +60,7 @@ func (pe *pipeExtract) updateNeededFields(neededFields, unneededFields fieldsSet
 	}
 }
 
-func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor {
+func (pe *pipeExtract) newPipeProcessor(workersCount int, _ <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor {
 	shards := make([]pipeExtractProcessorShard, workersCount)
 	for i := range shards {
 		ef := newExtractFormat(pe.steps)
@@ -78,7 +78,6 @@ func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}
 
 	pep := &pipeExtractProcessor{
 		pe:     pe,
-		stopCh: stopCh,
 		ppBase: ppBase,
 
 		shards: shards,
@@ -88,7 +87,6 @@ func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}
 
 type pipeExtractProcessor struct {
 	pe     *pipeExtract
-	stopCh <-chan struct{}
 	ppBase pipeProcessor
 
 	shards []pipeExtractProcessorShard