From d416e977aaa29c67a7a5b4989cfea577893e4102 Mon Sep 17 00:00:00 2001 From: Monet Lee Date: Thu, 1 Aug 2024 14:29:36 +0800 Subject: [PATCH] update log contents. --- internal/rpc/conversation/conversaion.go | 1 - internal/tools/cron_task.go | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/rpc/conversation/conversaion.go b/internal/rpc/conversation/conversaion.go index 0d21b3299..4cf20f919 100644 --- a/internal/rpc/conversation/conversaion.go +++ b/internal/rpc/conversation/conversaion.go @@ -611,7 +611,6 @@ func (c *conversationServer) GetOwnerConversation(ctx context.Context, req *pbco } func (c *conversationServer) GetConversationsNeedDestructMsgs(ctx context.Context, _ *pbconversation.GetConversationsNeedDestructMsgsReq) (*pbconversation.GetConversationsNeedDestructMsgsResp, error) { - log.ZInfo(ctx, "ConversationDestructMsgs cron start") num, err := c.conversationDatabase.GetAllConversationIDsNumber(ctx) if err != nil { log.ZError(ctx, "GetAllConversationIDsNumber failed", err) diff --git a/internal/tools/cron_task.go b/internal/tools/cron_task.go index ffa54709d..3a9ce6da9 100644 --- a/internal/tools/cron_task.go +++ b/internal/tools/cron_task.go @@ -93,7 +93,7 @@ func Start(ctx context.Context, config *CronTaskConfig) error { msgDestructFunc := func() { now := time.Now() ctx := mcontext.SetOperationID(ctx, fmt.Sprintf("cron_%d_%d", os.Getpid(), now.UnixMilli())) - log.ZInfo(ctx, "msg destruct ", "now", now) + log.ZInfo(ctx, "msg destruct cron start", "now", now) conversations, err := conversationClient.GetConversationsNeedDestructMsgs(ctx, &pbconversation.GetConversationsNeedDestructMsgsReq{}) if err != nil {