Defer close tailer

grafana · Feb 20, 2024 · 901d4d9 · 901d4d9
1 parent 9e39142
commit 901d4d9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/ingester/tailer.go b/pkg/ingester/tailer.go
@@ -116,10 +116,10 @@ func (t *tailer) loop() {
 }
 
 func (t *tailer) receiveStreamsLoop() {
+	defer t.close()
 	for {
 		select {
 		case <-t.conn.Context().Done():
-			t.close()
 			return
 		case <-t.closeChan:
 			return