From d660a7f18192f3c7f838627974d712e14d9fc4e7 Mon Sep 17 00:00:00 2001
From: Andrei Cheboksarov <37665782+cheb0@users.noreply.github.com>
Date: Mon, 27 Jul 2026 16:27:45 +0400
Subject: [PATCH] fix active frac hang

---
 frac/active.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/frac/active.go b/frac/active.go
index 2907d9c5..43ebd2bc 100644
--- a/frac/active.go
+++ b/frac/active.go
@@ -332,12 +332,13 @@ var bulkStagesSeconds = promauto.NewHistogramVec(prometheus.HistogramOpts{
 	Help:      "Bulk processing time by stage",
 }, []string{"stage"})
 
-// Append causes data to be written on disk and sends metas to index workers
+// Append causes data to be written on disk and sends metas to index workers.
 func (f *Active) Append(docs storage.DocBlock, metas storage.WalBlock, wg *sync.WaitGroup) (err error) {
 	sw := stopwatch.New()
 	m := sw.Start("append")
 	if err = f.writer.Write(docs, metas, sw); err != nil {
 		m.Stop()
+		wg.Done()
 		return err
 	}
 	f.updateDiskStats(uint64(len(docs)), uint64(len(metas)))