diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go index 6cd3be11e1..7dcdc3261d 100644 --- a/flow/connectors/postgres/postgres.go +++ b/flow/connectors/postgres/postgres.go @@ -397,13 +397,9 @@ func pullCore[Items model.Items]( if err != nil { return err } - var childToParentRelIDMap map[uint32]uint32 - // only initialize the map if needed, escape hatch because custom publications may not have the right setting - if req.OverridePublicationName != "" || pgVersion < shared.POSTGRES_13 { - childToParentRelIDMap, err = GetChildToParentRelIDMap(ctx, c.conn, slices.Collect(maps.Keys(req.SrcTableIDNameMapping))) - if err != nil { - return fmt.Errorf("error getting child to parent relid map: %w", err) - } + childToParentRelIDMap, err := GetChildToParentRelIDMap(ctx, c.conn, slices.Collect(maps.Keys(req.SrcTableIDNameMapping))) + if err != nil { + return fmt.Errorf("error getting child to parent relid map: %w", err) } if err := c.MaybeStartReplication(ctx, slotName, publicationName, req.LastOffset, pgVersion); err != nil {