Fix stage_batches bug

cffls · Oct 7, 2024 · ef89a9d · ef89a9d
1 parent 71fd49e
commit ef89a9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zk/stages/stage_batches.go b/zk/stages/stage_batches.go
@@ -225,7 +225,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()