stellar#4433: fixed race condition during index flush

sreuland · Jul 12, 2022 · be847d1 · be847d1
1 parent ad2b90a
commit be847d1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/exp/lighthorizon/index/backend/parallel_flush.go b/exp/lighthorizon/index/backend/parallel_flush.go
@@ -21,7 +21,9 @@ func parallelFlush(parallel uint32, allIndexes map[string]types.NamedIndices, f
 
 	batches := make(chan *batch, parallel)
 
+	wg.Add(1)
 	go func() {
+		defer wg.Done()
 		for account, indexes := range allIndexes {
 			batches <- &batch{
 				account: account,