diff --git a/flytestdlib/cache/in_memory_auto_refresh_test.go b/flytestdlib/cache/in_memory_auto_refresh_test.go index 84a4a7671e..276ec34e25 100644 --- a/flytestdlib/cache/in_memory_auto_refresh_test.go +++ b/flytestdlib/cache/in_memory_auto_refresh_test.go @@ -9,7 +9,6 @@ import ( "time" "github.com/stretchr/testify/assert" - "github.com/stretchr/testify/require" "k8s.io/client-go/util/workqueue" testingclock "k8s.io/utils/clock/testing" @@ -163,7 +162,7 @@ func TestCacheFour(t *testing.T) { // If the cache tries to enqueue the item, a panic will be thrown. assert.Eventually(t, func() bool { return cache.enqueueCount.Load() > enqueueCount }, time.Second, time.Millisecond) // Should not enqueue - require.Equal(t, syncCount, cache.syncCount.Load()) + assert.Equal(t, syncCount, cache.syncCount.Load()) syncCount = cache.syncCount.Load() enqueueCount = cache.enqueueCount.Load() @@ -172,7 +171,7 @@ func TestCacheFour(t *testing.T) { // If the cache tries to enqueue the item, a panic will be thrown. assert.Eventually(t, func() bool { return cache.enqueueCount.Load() > enqueueCount }, time.Second, time.Millisecond) // Should not enqueue - require.Equal(t, syncCount, cache.syncCount.Load()) + assert.Equal(t, syncCount, cache.syncCount.Load()) cancel() }) @@ -200,7 +199,7 @@ func TestCacheFour(t *testing.T) { // If the cache tries to enqueue the item, a panic will be thrown. assert.Eventually(t, func() bool { return cache.enqueueCount.Load() > enqueueCount }, time.Second, time.Millisecond) // Should not enqueue - require.Equal(t, syncCount, cache.syncCount.Load()) + assert.Equal(t, syncCount, cache.syncCount.Load()) err = cache.DeleteDelayed(itemID) assert.NoError(t, err)