diff --git a/internal/cron_task/clear_msg.go b/internal/cron_task/clear_msg.go index 8703b519b..1fafb3a14 100644 --- a/internal/cron_task/clear_msg.go +++ b/internal/cron_task/clear_msg.go @@ -188,9 +188,10 @@ func checkMaxSeqWithMongo(operationID, ID string, diffusionType int) error { } if err != nil { if err == goRedis.Nil { - return nil + + } else { + return utils.Wrap(err, "GetUserMaxSeq failed") } - return utils.Wrap(err, "GetUserMaxSeq failed") } msg, err := db.DB.GetNewestMsg(ID) if err != nil {