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 {
642
642
publication : Option < & str > ,
643
643
) -> EtlResult < Vec < ColumnSchema > > {
644
644
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 {
653
646
(
654
647
format ! (
655
648
"with pub_attrs as (
@@ -669,7 +662,7 @@ impl PgReplicationClient {
669
662
)" ,
670
663
)
671
664
} 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
673
666
(
674
667
format ! (
675
668
"with pub_table as (
You can’t perform that action at this time.
0 commit comments