File tree Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -642,14 +642,7 @@ impl PgReplicationClient {
642642 publication : Option < & str > ,
643643 ) -> EtlResult < Vec < ColumnSchema > > {
644644 let ( pub_cte, pub_pred) = if let Some ( publication) = publication {
645- let is_pg14_or_earlier = if let Some ( server_version) = self . server_version {
646- server_version. get ( ) < 150000
647- } else {
648- // be conservative by default
649- true
650- } ;
651-
652- if !is_pg14_or_earlier {
645+ if let Some ( server_version) = self . server_version && server_version. get ( ) >= 150000 {
653646 (
654647 format ! (
655648 "with pub_attrs as (
@@ -669,7 +662,7 @@ impl PgReplicationClient {
669662 )" ,
670663 )
671664 } else {
672- // No column-level filtering, check if table is in publication
665+ // Postgres 14 or earlier or unknown, fallback to no column-level filtering
673666 (
674667 format ! (
675668 "with pub_table as (
You can’t perform that action at this time.
0 commit comments