未验证 提交 00042386 编写于 作者: X xige-16 提交者: GitHub

[skip e2e]Improve AddQueryChannel log (#14962)

Signed-off-by: Nxige-16 <xi.ge@zilliz.com>
上级 d5b62973
...@@ -116,7 +116,11 @@ func (node *QueryNode) AddQueryChannel(ctx context.Context, in *queryPb.AddQuery ...@@ -116,7 +116,11 @@ func (node *QueryNode) AddQueryChannel(ctx context.Context, in *queryPb.AddQuery
log.Error(err.Error()) log.Error(err.Error())
return status, nil return status, nil
} }
log.Debug("addQueryChannelTask Enqueue done", zap.Any("collectionID", in.CollectionID)) log.Debug("addQueryChannelTask Enqueue done",
zap.Int64("collectionID", in.CollectionID),
zap.String("queryChannel", in.QueryChannel),
zap.String("queryResultChannel", in.QueryResultChannel),
)
waitFunc := func() (*commonpb.Status, error) { waitFunc := func() (*commonpb.Status, error) {
err = dct.WaitToFinish() err = dct.WaitToFinish()
...@@ -128,7 +132,12 @@ func (node *QueryNode) AddQueryChannel(ctx context.Context, in *queryPb.AddQuery ...@@ -128,7 +132,12 @@ func (node *QueryNode) AddQueryChannel(ctx context.Context, in *queryPb.AddQuery
log.Error(err.Error()) log.Error(err.Error())
return status, nil return status, nil
} }
log.Debug("addQueryChannelTask WaitToFinish done", zap.Any("collectionID", in.CollectionID)) log.Debug("addQueryChannelTask WaitToFinish done",
zap.Int64("collectionID", in.CollectionID),
zap.String("queryChannel", in.QueryChannel),
zap.String("queryResultChannel", in.QueryResultChannel),
)
return &commonpb.Status{ return &commonpb.Status{
ErrorCode: commonpb.ErrorCode_Success, ErrorCode: commonpb.ErrorCode_Success,
}, nil }, nil
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册