From cb23d9c64b2983c85f19b1bb9f7927f6cd679a3c Mon Sep 17 00:00:00 2001
From: ychao_1983 <ychao_1983@sina.com>
Date: Thu, 8 Dec 2022 08:57:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/cloudbrain/clear.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/services/cloudbrain/clear.go b/services/cloudbrain/clear.go
index 2cefb8341..bbdfdd024 100644
--- a/services/cloudbrain/clear.go
+++ b/services/cloudbrain/clear.go
@@ -27,6 +27,7 @@ func ClearCloudbrainResultSpace() {
 	for _, task := range tasks {
 		err := DeleteCloudbrainOneJobStorage(task.JobName)
 		if err == nil {
+			log.Info("clear job in cloudbrain table:"+task.JobName)
 			ids = append(ids, task.ID)
 		}
 	}
@@ -58,6 +59,7 @@ func clearMinioHistoryTrashFile() {
 
 			if file.ModTime().Before(time.Now().AddDate(0, 0, -setting.ClearStrategy.TrashSaveDays)) {
 				dirPath := setting.CBCodePathPrefix + file.Name() + "/"
+				log.Info("clear job in minio trash:"+file.Name())
 				storage.Attachments.DeleteDir(dirPath)
 				processCount++
 				if processCount == setting.ClearStrategy.BatchSize {
@@ -83,6 +85,7 @@ func clearLocalHistoryTrashFile()  {
 			//清理n天前的历史垃圾数据，清理job目录
 			if file.ModTime().Before(time.Now().AddDate(0, 0, -setting.ClearStrategy.TrashSaveDays)) {
 				os.RemoveAll(setting.JobPath + file.Name())
+				log.Info("clear job in local trash:"+file.Name())
 				processCount++
 				if processCount == setting.ClearStrategy.BatchSize {
 					break