milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update ddnode test (#9477) 

Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
pull/9491/head
Cai Yudong 2021-10-08 17:43:46 +08:00 committed by GitHub
parent ce17e12819
commit 78755263e2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datanode/flow_graph_dd_node_test.go
View File

@ -120,13 +120,13 @@ func TestFlowGraph_DDNode_Operate(to *testing.T) {
collectionID: test.ddnCollID, collectionID: test.ddnCollID,
} }
var createCollMsg msgstream.TsMsg = &msgstream.DropCollectionMsg{ var dropCollMsg msgstream.TsMsg = &msgstream.DropCollectionMsg{
DropCollectionRequest: internalpb.DropCollectionRequest{ DropCollectionRequest: internalpb.DropCollectionRequest{
Base: &commonpb.MsgBase{MsgType: commonpb.MsgType_DropCollection}, Base: &commonpb.MsgBase{MsgType: commonpb.MsgType_DropCollection},
CollectionID: test.msgCollID, CollectionID: test.msgCollID,
}, },
} }
tsMessages := []msgstream.TsMsg{createCollMsg} tsMessages := []msgstream.TsMsg{dropCollMsg}
var msgStreamMsg Msg = flowgraph.GenerateMsgStreamMsg(tsMessages, 0, 0, nil, nil) var msgStreamMsg Msg = flowgraph.GenerateMsgStreamMsg(tsMessages, 0, 0, nil, nil)
rt := ddn.Operate([]Msg{msgStreamMsg}) rt := ddn.Operate([]Msg{msgStreamMsg})