未验证 提交 9b491858 编写于 作者: Y yah01 提交者: GitHub

Fix datanode unit test not stable (#21911)

Signed-off-by: Nyah01 <yang.cen@zilliz.com>
上级 53ae40b8
......@@ -293,11 +293,11 @@ func TestWatchChannel(t *testing.T) {
err = kv.RemoveWithPrefix(fmt.Sprintf("%s/%d", Params.CommonCfg.DataCoordWatchSubPath.GetValue(), paramtable.GetNodeID()))
assert.Nil(t, err)
//TODO there is not way to sync Release done, use sleep for now
time.Sleep(100 * time.Millisecond)
exist = node.flowgraphManager.exist(ch)
assert.False(t, exist)
assert.Eventually(t, func() bool {
exist = node.flowgraphManager.exist(ch)
return !exist
}, 3*time.Second, 100*time.Millisecond)
})
t.Run("Test release channel", func(t *testing.T) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册