diff --git a/pkg/compute/service/service.go b/pkg/compute/service/service.go index bc41ecc8b3..bd4623bd21 100644 --- a/pkg/compute/service/service.go +++ b/pkg/compute/service/service.go @@ -63,7 +63,6 @@ func StartService() { cron.AddJob2("AutoDiskSnapshot", options.Options.AutoSnapshotDay, options.Options.AutoSnapshotHour, 0, 0, models.DiskManager.AutoDiskSnapshot, false) cron.AddJob2("SyncSkus", options.Options.SyncSkusDay, options.Options.SyncSkusHour, 0, 0, skus.SyncSkus, true) - cron.AddJob2("CleanInvalidSkus", options.Options.SyncSkusDay, options.Options.SyncSkusHour, 0, 0, skus.DeleteInvalidSkus, true) // skus只在启动时进行清理 cron.Start() defer cron.Stop() diff --git a/pkg/compute/skus/skus.go b/pkg/compute/skus/skus.go index 5ec475b3e9..bbbb4ae511 100644 --- a/pkg/compute/skus/skus.go +++ b/pkg/compute/skus/skus.go @@ -321,6 +321,10 @@ func SyncSkus(ctx context.Context, userCred mcclient.TokenCredential, isStart bo if e := skus.SyncToLocalDB(); e != nil { log.Errorf("SyncSkus sync to local db failed, %s", e.Error()) } + + // 清理无效的sku + log.Debugf("DeleteInvalidSkus in processing...") + models.ServerSkuManager.PendingDeleteInvalidSku() } // 同步指定provider sku列表 @@ -337,11 +341,3 @@ func SyncSkusByProviderIds(providerIds []string) error { return nil } - -// 伪删除无效的sku.只在启动进程时进行清理。 -func DeleteInvalidSkus(ctx context.Context, userCred mcclient.TokenCredential, isStart bool) { - if isStart { - log.Debugf("DeleteInvalidSkus in processing...") - models.ServerSkuManager.PendingDeleteInvalidSku() - } -}