From a55e01e4068c379ddfeb305234213d57762eef1f Mon Sep 17 00:00:00 2001
From: Aliaksandr Valialkin <valyala@victoriametrics.com>
Date: Sat, 11 May 2024 08:06:33 +0200
Subject: [PATCH] wip

---
 lib/logstorage/storage_search.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/logstorage/storage_search.go b/lib/logstorage/storage_search.go
index e24b9c589..b76138762 100644
--- a/lib/logstorage/storage_search.go
+++ b/lib/logstorage/storage_search.go
@@ -99,8 +99,8 @@ func (s *Storage) RunQuery(ctx context.Context, tenantIDs []TenantID, q *Query,
 	for i := len(q.pipes) - 1; i >= 0; i-- {
 		p := q.pipes[i]
 		ctxChild, cancel := context.WithCancel(ctx)
-		stopCh = ctxChild.Done()
 		pp = p.newPipeProcessor(workersCount, stopCh, cancel, pp)
+		stopCh = ctxChild.Done()
 		ctx = ctxChild
 
 		cancels[i] = cancel