lywsvip/cloudpods
1
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-06-05 19:26:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: clean task job batch limit not effect (#22240)

Browse Source 
Co-authored-by: Qiu Jian <qiujian@yunionyun.com>
This commit is contained in:
Jian Qiu
2025-03-07 16:36:14 +08:00
committed by GitHub
parent f794cb43f0
commit 16ee2ff0ee
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/cloudcommon/db/taskman/tasks.go
View File

@@ -1439,7 +1439,6 @@ func (manager *STaskManager) TaskCleanupJob(ctx context.Context, userCred mcclie
count := 0
for rows.Next() {
task := STask{}
task.SetModelManager(manager, &task)
err := q.Row2Struct(rows, &task)
if err != nil {
@@ -1447,6 +1446,7 @@ func (manager *STaskManager) TaskCleanupJob(ctx context.Context, userCred mcclie
return
}
task.SetModelManager(ArchivedTaskManager, &task)
err = ArchivedTaskManager.Insert(ctx, &task)
if err != nil {
log.Errorf("insert archive fail %s", err)
@@ -1468,5 +1468,5 @@ func (manager *STaskManager) TaskCleanupJob(ctx context.Context, userCred mcclie
count++
}
log.Infof("TaskCleanupJob migrate %d tasks, takes %f seconds", count, time.Since(taskStart).Seconds())
log.Infof("TaskCleanupJob migrate %d tasks, takes %f seconds, batch limit=%d threshold hours=%d", count, time.Since(taskStart).Seconds(), consts.TaskArchiveBatchLimit(), consts.TaskArchiveThresholdHours())
}