diff --git a/pkg/local_object_storage/shard/delete_test.go b/pkg/local_object_storage/shard/delete_test.go index aba204f3..bfafcdc7 100644 --- a/pkg/local_object_storage/shard/delete_test.go +++ b/pkg/local_object_storage/shard/delete_test.go @@ -3,6 +3,7 @@ package shard_test import ( "context" "testing" + "time" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/core/object" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/internal/testutil" @@ -56,8 +57,10 @@ func testShardDelete(t *testing.T, hasWriteCache bool) { _, err = sh.Delete(context.TODO(), delPrm) require.NoError(t, err) - _, err = sh.Get(context.Background(), getPrm) - require.True(t, client.IsErrObjectNotFound(err)) + require.Eventually(t, func() bool { + _, err = sh.Get(context.Background(), getPrm) + return client.IsErrObjectNotFound(err) + }, time.Second, 50*time.Millisecond) }) t.Run("small object", func(t *testing.T) { @@ -80,7 +83,9 @@ func testShardDelete(t *testing.T, hasWriteCache bool) { _, err = sh.Delete(context.Background(), delPrm) require.NoError(t, err) - _, err = sh.Get(context.Background(), getPrm) - require.True(t, client.IsErrObjectNotFound(err)) + require.Eventually(t, func() bool { + _, err = sh.Get(context.Background(), getPrm) + return client.IsErrObjectNotFound(err) + }, time.Second, 50*time.Millisecond) }) } diff --git a/pkg/local_object_storage/shard/shard_test.go b/pkg/local_object_storage/shard/shard_test.go index 1083bf01..6337b0b6 100644 --- a/pkg/local_object_storage/shard/shard_test.go +++ b/pkg/local_object_storage/shard/shard_test.go @@ -101,7 +101,7 @@ func newCustomShard(t testing.TB, rootPath string, enableWriteCache bool, wcOpts require.NoError(t, err) return pool }), - shard.WithGCRemoverSleepInterval(1 * time.Millisecond), + shard.WithGCRemoverSleepInterval(100 * time.Millisecond), } sh = shard.New(opts...)