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

[skip e2e] Add comment for consumerFlowGraph (#14000) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/14016/head
bigsheeper 2021-12-22 20:19:50 +08:00 committed by GitHub
parent 7d38720ec9
commit e6ea9c140c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/querynode/flow_graph_query_node.go
View File

@ -189,6 +189,7 @@ func (q *queryNodeFlowGraph) newDmInputNode(ctx context.Context, factory msgstre
return node return node
} }
// consumerFlowGraph would consume by channel and subName
func (q *queryNodeFlowGraph) consumerFlowGraph(channel Channel, subName ConsumeSubName) error { func (q *queryNodeFlowGraph) consumerFlowGraph(channel Channel, subName ConsumeSubName) error {
if q.dmlStream == nil { if q.dmlStream == nil {
return errors.New("null dml message stream in flow graph") return errors.New("null dml message stream in flow graph")