Skip to content

Commit

Permalink
crosscluster/logical: elide status msg when caught up
Browse files Browse the repository at this point in the history
Release note: none.
Epic: none.
  • Loading branch information
dt committed Nov 9, 2024
1 parent ac71c8a commit 879a89a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion pkg/ccl/crosscluster/logical/range_stats.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ func (r *rangeStatsByProcessorID) RollupStats() (streampb.StreamEvent_RangeStats
if total.LaggingRangeCount != 0 {
return total, fractionCompleted, fmt.Sprintf("catching up on %d out of %d ranges", total.LaggingRangeCount, total.RangeCount)
}
return total, 1, fmt.Sprintf("all %d ranges are caught up", total.RangeCount)
return total, 1, ""
}

func newRangeStatsCollector(processorCount int) rangeStatsByProcessorID {
Expand Down
2 changes: 1 addition & 1 deletion pkg/ccl/crosscluster/logical/range_stats_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ func TestRangeStats(t *testing.T) {
RangeCount: 10,
},
fraction: 1,
expectedMsg: "all 10 ranges are caught up",
expectedMsg: "",
inputStats: map[int32]*streampb.StreamEvent_RangeStats{
1: {RangeCount: 5},
2: {RangeCount: 3},
Expand Down

0 comments on commit 879a89a

Please sign in to comment.