From b5f717c007277f47fe4db209a9ba7902d5e94fdb Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Fri, 19 Jan 2024 22:22:13 +0530 Subject: [PATCH] minor change --- flow/cmd/validate_mirror.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/cmd/validate_mirror.go b/flow/cmd/validate_mirror.go index 5ae070a32e..b5cd12b624 100644 --- a/flow/cmd/validate_mirror.go +++ b/flow/cmd/validate_mirror.go @@ -25,7 +25,7 @@ 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{ @@ -33,7 +33,7 @@ func (h *FlowRequestHandler) ValidateCDCMirror( }, 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)