Fix stage_batches bug

cffls · Oct 8, 2024 · 18ab8dd · 18ab8dd
1 parent 44ac160
commit 18ab8dd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zk/stages/stage_batches.go b/zk/stages/stage_batches.go
@@ -219,7 +219,7 @@ func SpawnStageBatches(
 	// start routine to download blocks and push them in a channel
 	dsClientRunner := NewDatastreamClientRunner(cfg.dsClient, logPrefix)
 	dsClientRunner.StartRead()
-	defer dsClientRunner.StartRead()
+	defer dsClientRunner.StopRead()
 
 	entryChan := cfg.dsClient.GetEntryChan()