defer close

PeerDB-io · Feb 15, 2024 · 85e7465 · 85e7465
1 parent 2f63b4d
commit 85e7465
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go
@@ -119,6 +119,8 @@ func (c *PostgresConnector) CheckReplicationConnectivity(ctx context.Context) er
 		return fmt.Errorf("failed to create replication connection: %v", err)
 	}
 
+	defer conn.Close(ctx)
+
 	var one int
 	queryErr := conn.QueryRow(ctx, "SELECT 1").Scan(&one)
 	if queryErr != nil {