chore: fix TestBreakerConcurrent ci

bytedance · Jul 26, 2024 · 098c104 · 098c104
1 parent c388956
commit 098c104
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cloud/circuitbreaker/breaker_test.go b/cloud/circuitbreaker/breaker_test.go
@@ -292,7 +292,10 @@ func TestBreakerConcurrent(t *testing.T) {
 			var wg sync.WaitGroup
 			pass := int32(0)
 			fail := int32(0)
-			for i := 0; i < 50; i++ {
+			if b.IsAllowed() {
+				atomic.AddInt32(&pass, 1)
+			}
+			for i := 0; i < 49; i++ {
 				wg.Add(1)
 				go func() {
 					defer wg.Done()