Skip to content

Commit

Permalink
remove unused method
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Jan 5, 2024
1 parent b797ff1 commit f59e148
Showing 1 changed file with 0 additions and 23 deletions.
23 changes: 0 additions & 23 deletions flow/cmd/mirror_status.go
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit f59e148

Please sign in to comment.