test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 02:48:45 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

fix: Fix the unstable unit test TestReplicateManager (#28718)

Browse Source 
/kind improvement

Signed-off-by: SimFG <bang.fu@zilliz.com>
This commit is contained in:
SimFG 2023-11-24 17:50:30 +08:00 committed by GitHub
parent 86ccb8e146
commit 089e58dfbb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/proxy/replicate_stream_manager_test.go
View File

@ -52,7 +52,10 @@ func TestReplicateManager(t *testing.T) {
assert.Equal(t, 3, i) assert.Equal(t, 3, i)
res := resourceManager.Delete(ReplicateMsgStreamTyp, "test") res := resourceManager.Delete(ReplicateMsgStreamTyp, "test")
assert.NotNil(t, res) assert.NotNil(t, res)
time.Sleep(2 * time.Second)
assert.Eventually(t, func() bool {
return resourceManager.Delete(ReplicateMsgStreamTyp, "test") == nil
}, time.Second*4, time.Millisecond*500)
_, err = manager.GetReplicateMsgStream(context.Background(), "test") _, err = manager.GetReplicateMsgStream(context.Background(), "test")
assert.NoError(t, err) assert.NoError(t, err)
@ -61,7 +64,10 @@ func TestReplicateManager(t *testing.T) {
{ {
res := resourceManager.Delete(ReplicateMsgStreamTyp, "test") res := resourceManager.Delete(ReplicateMsgStreamTyp, "test")
assert.NotNil(t, res) assert.NotNil(t, res)
time.Sleep(2 * time.Second)
assert.Eventually(t, func() bool {
return resourceManager.Delete(ReplicateMsgStreamTyp, "test") == nil
}, time.Second*4, time.Millisecond*500)
res, err := resourceManager.Get(ReplicateMsgStreamTyp, "test", func() (resource.Resource, error) { res, err := resourceManager.Get(ReplicateMsgStreamTyp, "test", func() (resource.Resource, error) {
return resource.NewResource(resource.WithObj("str")), nil return resource.NewResource(resource.WithObj("str")), nil