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