Commit695afb8

authored

fix: address TestPendingUpdatesMetric flake

1 parent966c888 commit695afb8Copy full SHA for 695afb8

File tree

-3

lines changed

-3

lines changed

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -254,9 +254,10 @@ func TestPendingUpdatesMetric(t *testing.T) {`
`254`	`254`	`success:=testutil.RequireRecvCtx(testutil.Context(t,testutil.WaitShort),t,interceptor.updateSuccess)`
`255`	`255`	`failure:=testutil.RequireRecvCtx(testutil.Context(t,testutil.WaitShort),t,interceptor.updateFailure)`
`256`	`256`
`257`		`-// Ensure that the value set in the metric is equivalent to the number of actual pending updates.`
`258`		`-pending:=promtest.ToFloat64(metrics.PendingUpdates)`
`259`		`-require.EqualValues(t,pending,success+failure)`
	`257`	`+// Wait for the metric to be updated with the expected count of metrics.`
	`258`	`+require.Eventually(t,func()bool {`
	`259`	`+returnpromtest.ToFloat64(metrics.PendingUpdates)==float64(success+failure)`
	`260`	`+},testutil.WaitShort,testutil.IntervalFast)`
`260`	`261`
`261`	`262`	`// Unpause the interceptor so the updates can proceed.`
`262`	`263`	`interceptor.unpause()`

Comments

(0)