diff --git a/common/quotas/clocked_rate_limiter_test.go b/common/quotas/clocked_rate_limiter_test.go index 15a0abcf338..1c48dd6514e 100644 --- a/common/quotas/clocked_rate_limiter_test.go +++ b/common/quotas/clocked_rate_limiter_test.go @@ -154,6 +154,7 @@ func TestClockedRateLimiter_Wait_DeadlineWouldExceed(t *testing.T) { // test that reservations for 1 token ARE unblocked by RecycleToken func TestClockedRateLimiter_Wait_Recycle(t *testing.T) { + t.Skip("flaky test") t.Parallel() ts := clock.NewEventTimeSource() rl := quotas.NewClockedRateLimiter(rate.NewLimiter(1, 1), ts) @@ -180,6 +181,7 @@ func TestClockedRateLimiter_Wait_Recycle(t *testing.T) { // test that reservations for >1 token are NOT unblocked by RecycleToken func TestClockedRateLimiter_WaitN_NoRecycle(t *testing.T) { + t.Skip("flaky test") t.Parallel() ts := clock.NewEventTimeSource() diff --git a/service/matching/matcher_test.go b/service/matching/matcher_test.go index 2a2fdffd347..d8e3d223991 100644 --- a/service/matching/matcher_test.go +++ b/service/matching/matcher_test.go @@ -370,6 +370,7 @@ func (t *MatcherTestSuite) TestAvoidForwardingWhenBacklogIsOld() { } func (t *MatcherTestSuite) TestBacklogAge() { + t.T().Skip("flaky test") t.Equal(emptyBacklogAge, t.rootMatcher.getBacklogAge()) youngBacklogTask := newInternalTaskFromBacklog(randomTaskInfoWithAge(time.Second), nil)