diff --git a/pkg/services/live/pushws/push_pipeline.go b/pkg/services/live/pushws/push_pipeline.go
index 5651a5d4227..4d6b6f38160 100644
--- a/pkg/services/live/pushws/push_pipeline.go
+++ b/pkg/services/live/pushws/push_pipeline.go
@@ -55,11 +55,13 @@ func (s *PipelinePushHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
 	if err != nil {
 		return
 	}
+	defer func() { _ = conn.Close() }()
 	setupWSConn(r.Context(), conn, s.config)
 
 	for {
 		_, body, err := conn.ReadMessage()
 		if err != nil {
+			logger.Debug("Error reading websocket connection", "error", err)
 			break
 		}
 
diff --git a/pkg/services/live/pushws/push_stream.go b/pkg/services/live/pushws/push_stream.go
index a7892df2b97..0b1ffbdabbb 100644
--- a/pkg/services/live/pushws/push_stream.go
+++ b/pkg/services/live/pushws/push_stream.go
@@ -57,11 +57,13 @@ func (s *Handler) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
 	if err != nil {
 		return
 	}
+	defer func() { _ = conn.Close() }()
 	setupWSConn(r.Context(), conn, s.config)
 
 	for {
 		_, body, err := conn.ReadMessage()
 		if err != nil {
+			logger.Debug("Error reading websocket connection", "error", err)
 			break
 		}