danvics/Pulse
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(test): resolve flaky concurrent temperature collection test

Browse source
This commit is contained in:
rcourtman 2025-12-19 17:09:57 +00:00
parent a535b22849
commit b4db8b160b
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
internal/monitoring/temperature_test.go
View file

@ -647,7 +647,10 @@ func TestTemperatureCollector_ConcurrentCollectTemperature(t *testing.T) {
stub := &stubTemperatureProxy{ stub := &stubTemperatureProxy{
responseFunc: func(int) stubProxyResponse { responseFunc: func(int) stubProxyResponse {
n := atomic.AddInt32(&callCounter, 1) n := atomic.AddInt32(&callCounter, 1)
if n%2 == 1 { // Only fail every 5th call to avoid hitting the consecutive failure threshold (3)
// due to concurrent execution ordering. n%2 was causing flaky failures where
// 3 failures could happen before a success reset the counter.
if n%5 == 0 {
return stubProxyResponse{ return stubProxyResponse{
err: &tempproxy.ProxyError{Type: tempproxy.ErrorTypeTransport, Message: "transient transport error"}, err: &tempproxy.ProxyError{Type: tempproxy.ErrorTypeTransport, Message: "transient transport error"},
} }