fix: terminate session flush

vinceanalytics · Mar 3, 2024 · 65278d2 · 65278d2
1 parent ad93080
commit 65278d2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/session/session.go b/internal/session/session.go
@@ -115,6 +115,7 @@ func (s *Session) Flush() {
 	wg.Wait()
 }
 func (s *Session) append(wg *sync.WaitGroup, tenantId string, r arrow.Record) {
+	defer wg.Done()
 	defer r.Release()
 	err := s.tree.Add(tenantId, r)
 	if err != nil {