diff --git a/cdnsystem/supervisor/cdn/storage/storage_gc.go b/cdnsystem/supervisor/cdn/storage/storage_gc.go index 7d086de78..6938f3ad4 100644 --- a/cdnsystem/supervisor/cdn/storage/storage_gc.go +++ b/cdnsystem/supervisor/cdn/storage/storage_gc.go @@ -100,10 +100,7 @@ func (cleaner *Cleaner) GC(storagePattern string, force bool) ([]string, error) walkTaskIds[taskID] = true // we should return directly when we success to get info which means it is being used - if _, err := cleaner.taskMgr.Get(taskID); err == nil || !cdnerrors.IsDataNotFound(err) { - if err != nil { - logger.GcLogger.With("type", storagePattern).Errorf("failed to get taskID(%s): %v", taskID, err) - } + if cleaner.taskMgr.Exist(taskID) { return nil } diff --git a/cdnsystem/supervisor/task/manager.go b/cdnsystem/supervisor/task/manager.go index 538feb952..d9be8db2f 100644 --- a/cdnsystem/supervisor/task/manager.go +++ b/cdnsystem/supervisor/task/manager.go @@ -182,7 +182,7 @@ func (tm Manager) Get(taskID string) (*types.SeedTask, error) { } func (tm Manager) Exist(taskID string) bool { - _, err := tm.taskStore.Get(taskID) + _, err := tm.getTask(taskID) return err == nil || !cdnerrors.IsDataNotFound(err) }