Avoid calling Close on nil connection

PeerDB-io · Feb 9, 2024 · 7e24789 · 7e24789
1 parent b73aa5f
commit 7e24789
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -227,7 +227,9 @@ func (c *PostgresConnector) replicationOptions(publicationName string) (*pglogre
 // Close closes all connections.
 func (c *PostgresConnector) Close() error {
 	if c != nil {
-		c.replConn.Close(c.ctx)
+		if c.replConn != nil {
+			c.replConn.Close(c.ctx)
+		}
 		c.conn.Close(c.ctx)
 		c.ssh.Close()
 	}