From e8b1b56467d74ae38ad6b6721a1239772b16d58d Mon Sep 17 00:00:00 2001
From: dragondriver <jiquan.long@zilliz.com>
Date: Tue, 7 Dec 2021 21:05:15 +0800
Subject: [PATCH] Refine log of DescribeCollection (#12619)

Signed-off-by: dragondriver <jiquan.long@zilliz.com>
---
 internal/proxy/impl.go | 50 +++++++++++++++++++++++++++++++-----------
 1 file changed, 37 insertions(+), 13 deletions(-)

diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go
index d8950b66d..53be36197 100644
--- a/internal/proxy/impl.go
+++ b/internal/proxy/impl.go
@@ -545,6 +545,11 @@ func (node *Proxy) DescribeCollection(ctx context.Context, request *milvuspb.Des
 			Status: unhealthyStatus(),
 		}, nil
 	}
+
+	sp, ctx := trace.StartSpanFromContextWithOperationName(ctx, "Proxy-Insert")
+	defer sp.Finish()
+	traceID, _, _ := trace.InfoFromSpan(sp)
+
 	dct := &describeCollectionTask{
 		ctx:                       ctx,
 		Condition:                 NewTaskCondition(ctx),
@@ -552,12 +557,20 @@ func (node *Proxy) DescribeCollection(ctx context.Context, request *milvuspb.Des
 		rootCoord:                 node.rootCoord,
 	}
 
-	log.Debug("DescribeCollection enqueue",
+	log.Debug("DescribeCollection received",
+		zap.String("traceID", traceID),
 		zap.String("role", Params.RoleName),
 		zap.String("db", request.DbName),
 		zap.String("collection", request.CollectionName))
-	err := node.sched.ddQueue.Enqueue(dct)
-	if err != nil {
+
+	if err := node.sched.ddQueue.Enqueue(dct); err != nil {
+		log.Warn("DescribeCollection failed to enqueue",
+			zap.Error(err),
+			zap.String("traceID", traceID),
+			zap.String("role", Params.RoleName),
+			zap.String("db", request.DbName),
+			zap.String("collection", request.CollectionName))
+
 		return &milvuspb.DescribeCollectionResponse{
 			Status: &commonpb.Status{
 				ErrorCode: commonpb.ErrorCode_UnexpectedError,
@@ -566,24 +579,26 @@ func (node *Proxy) DescribeCollection(ctx context.Context, request *milvuspb.Des
 		}, nil
 	}
 
-	log.Debug("DescribeCollection",
+	log.Debug("DescribeCollection enqueued",
+		zap.String("traceID", traceID),
 		zap.String("role", Params.RoleName),
-		zap.Int64("msgID", request.Base.MsgID),
-		zap.Uint64("timestamp", request.Base.Timestamp),
+		zap.Int64("MsgID", dct.ID()),
+		zap.Uint64("BeginTS", dct.BeginTs()),
+		zap.Uint64("EndTS", dct.EndTs()),
 		zap.String("db", request.DbName),
 		zap.String("collection", request.CollectionName))
-	defer func() {
-		log.Debug("DescribeCollection Done",
+
+	if err := dct.WaitToFinish(); err != nil {
+		log.Warn("DescribeCollection failed to WaitToFinish",
 			zap.Error(err),
+			zap.String("traceID", traceID),
 			zap.String("role", Params.RoleName),
-			zap.Int64("msgID", request.Base.MsgID),
-			zap.Uint64("timestamp", request.Base.Timestamp),
+			zap.Int64("MsgID", dct.ID()),
+			zap.Uint64("BeginTS", dct.BeginTs()),
+			zap.Uint64("EndTS", dct.EndTs()),
 			zap.String("db", request.DbName),
 			zap.String("collection", request.CollectionName))
-	}()
 
-	err = dct.WaitToFinish()
-	if err != nil {
 		return &milvuspb.DescribeCollectionResponse{
 			Status: &commonpb.Status{
 				ErrorCode: commonpb.ErrorCode_UnexpectedError,
@@ -592,6 +607,15 @@ func (node *Proxy) DescribeCollection(ctx context.Context, request *milvuspb.Des
 		}, nil
 	}
 
+	log.Debug("DescribeCollection done",
+		zap.String("traceID", traceID),
+		zap.String("role", Params.RoleName),
+		zap.Int64("MsgID", dct.ID()),
+		zap.Uint64("BeginTS", dct.BeginTs()),
+		zap.Uint64("EndTS", dct.EndTs()),
+		zap.String("db", request.DbName),
+		zap.String("collection", request.CollectionName))
+
 	return dct.result, nil
 }
 
-- 
GitLab