Pre-emptively recover sqlx close panics

stilingue-inteligencia-artificial · Mar 8, 2024 · b89b33c · b89b33c
1 parent eb08f57
commit b89b33c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/internal/impl/cockroachdb/input_changefeed.go b/internal/impl/cockroachdb/input_changefeed.go
@@ -190,6 +190,12 @@ func (c *crdbChangefeedInput) Connect(ctx context.Context) (err error) {
 }
 
 func (c *crdbChangefeedInput) closeConnection() {
+	defer func() {
+		if r := recover(); r != nil {
+			c.logger.Errorf("Recovered connection close panic: %v", r)
+		}
+	}()
+
 	c.dbMut.Lock()
 	defer c.dbMut.Unlock()