From f59e148502e232f008ad03076794febcb8177eb1 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Fri, 5 Jan 2024 09:07:55 -0500 Subject: [PATCH] remove unused method --- flow/cmd/mirror_status.go | 23 ----------------------- 1 file changed, 23 deletions(-) diff --git a/flow/cmd/mirror_status.go b/flow/cmd/mirror_status.go index b1ff64077b..65f9886f51 100644 --- a/flow/cmd/mirror_status.go +++ b/flow/cmd/mirror_status.go @@ -168,29 +168,6 @@ func (h *FlowRequestHandler) getPartitionStatuses( return res, nil } -func (h *FlowRequestHandler) getPartitionUUIDs( - ctx context.Context, - flowJobName string, -) ([]string, error) { - rows, err := h.pool.Query(ctx, - "SELECT partition_uuid FROM peerdb_stats.qrep_partitions WHERE flow_name = $1", flowJobName) - if err != nil { - return nil, fmt.Errorf("unable to query qrep partitions: %w", err) - } - defer rows.Close() - - partitionUUIDs := []string{} - for rows.Next() { - var partitionUUID pgtype.Text - if err := rows.Scan(&partitionUUID); err != nil { - return nil, fmt.Errorf("unable to scan partition row: %w", err) - } - partitionUUIDs = append(partitionUUIDs, partitionUUID.String) - } - - return partitionUUIDs, nil -} - func (h *FlowRequestHandler) getFlowConfigFromCatalog( flowJobName string, ) (*protos.FlowConnectionConfigs, error) {