Avoid calling Close on nil connection

PeerDB-io · Feb 8, 2024 · 7cdb75b · 7cdb75b
1 parent 5e47225
commit 7cdb75b
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()
 	}