Skip to content

Commit

Permalink
undoing renames for seperate PR pt.2
Browse files Browse the repository at this point in the history
  • Loading branch information
heavycrystal committed Nov 27, 2023
1 parent 7c77203 commit ef50c46
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions flow/connectors/postgres/cdc.go
Original file line number Diff line number Diff line change
Expand Up @@ -751,11 +751,11 @@ func (p *PostgresCDCSource) compositePKeyToString(req *model.PullRecordsRequest,
return fmt.Sprintf("%x", hasher.Sum(nil)), nil
}

func (p *PostgresCDCSource) getParentRelIdIfPartitioned(relID uint32) uint32 {
parentRelID, ok := p.chIdToParRelId[relID]
func (p *PostgresCDCSource) getParentRelIdIfPartitioned(relId uint32) uint32 {
parentRelId, ok := p.chIdToParRelId[relId]
if ok {
return parentRelID
return parentRelId
}

return relID
return relId
}

0 comments on commit ef50c46

Please sign in to comment.