Skip to content

Commit

Permalink
minor change
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Jan 19, 2024
1 parent 876eeb8 commit b5f717c
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions flow/cmd/validate_mirror.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@ func (h *FlowRequestHandler) ValidateCDCMirror(
return nil, fmt.Errorf("source peer config is nil")
}

// 2. Check permissions of postgres peer
// Check permissions of postgres peer
err = connpostgres.CheckReplicationPermissions(ctx, sourcePool, sourcePeerConfig.User)
if err != nil {
return &protos.ValidateCDCMirrorResponse{
Ok: false,
}, fmt.Errorf("failed to check replication permissions: %v", err)
}

// 3. Check source tables
// Check source tables
sourceTables := make([]string, 0, len(req.ConnectionConfigs.TableMappings))
for _, tableMapping := range req.ConnectionConfigs.TableMappings {
sourceTables = append(sourceTables, tableMapping.SourceTableIdentifier)
Expand Down

0 comments on commit b5f717c

Please sign in to comment.