From 84c5fd8b582977b8caf6e662abaa41b87227229d Mon Sep 17 00:00:00 2001 From: "Molecule AI Dev Engineer A (Kimi)" Date: Sun, 31 May 2026 22:42:59 +0000 Subject: [PATCH] fix(channels): check rows.Err() after iteration in manager handlers --- workspace-server/internal/channels/manager.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/workspace-server/internal/channels/manager.go b/workspace-server/internal/channels/manager.go index 63cfe9503..85d2adc12 100644 --- a/workspace-server/internal/channels/manager.go +++ b/workspace-server/internal/channels/manager.go @@ -156,6 +156,9 @@ func (m *Manager) PausePollersForToken(workspaceID, botToken string) func() { } } } + if err := rows.Err(); err != nil { + log.Printf("Channels: pause-pollers rows error: %v", err) + } m.mu.Unlock() if len(pausedIDs) == 0 { @@ -216,6 +219,9 @@ func (m *Manager) Reload(ctx context.Context) { } desired[ch.ID] = ch } + if err := rows.Err(); err != nil { + log.Printf("Channels: reload rows error: %v", err) + } m.mu.Lock() defer m.mu.Unlock() @@ -473,6 +479,9 @@ func (m *Manager) BroadcastToWorkspaceChannels(ctx context.Context, workspaceID, } } } + if err := rows.Err(); err != nil { + log.Printf("Channels: broadcast rows error: %v", err) + } } // FetchWorkspaceChannelContext returns recent Slack channel messages formatted -- 2.52.0