opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-19 02:37:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(cloudid): cloudid resource sync worker (#20878)

Browse Source
This commit is contained in:
屈轩
2024-07-25 11:19:20 +08:00
committed by GitHub
parent ebd7f5d5df
commit fda7529b3f
2 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cloudid/tasks/cloudaccount_sync_resources_task.go
+7 -1
View File
@@ -21,6 +21,7 @@ import (
"yunion.io/x/jsonutils"
"yunion.io/x/pkg/errors"
"yunion.io/x/onecloud/pkg/appsrv"
"yunion.io/x/onecloud/pkg/cloudcommon/db"
"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
"yunion.io/x/onecloud/pkg/cloudid/models"
@@ -30,8 +31,13 @@ type CloudaccountSyncResourcesTask struct {
taskman.STask
}
var (
CloudaccountSyncWorkerManager *appsrv.SWorkerManager
)
func init() {
taskman.RegisterTask(CloudaccountSyncResourcesTask{})
CloudaccountSyncWorkerManager = appsrv.NewWorkerManager("CloudaccountSyncWorkerManager", 10, 1024, false)
taskman.RegisterTaskAndWorker(CloudaccountSyncResourcesTask{}, CloudaccountSyncWorkerManager)
}
func (self *CloudaccountSyncResourcesTask) taskFailed(ctx context.Context, cloudaccount *models.SCloudaccount, err error) {
pkg/cloudid/tasks/cloudprovider_sync_resources_task.go
+7 -1
View File
@@ -21,6 +21,7 @@ import (
"yunion.io/x/jsonutils"
"yunion.io/x/pkg/errors"
"yunion.io/x/onecloud/pkg/appsrv"
"yunion.io/x/onecloud/pkg/cloudcommon/db"
"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
"yunion.io/x/onecloud/pkg/cloudid/models"
@@ -30,8 +31,13 @@ type CloudproviderSyncResourcesTask struct {
taskman.STask
}
var (
CloudproviderSyncWorkerManager *appsrv.SWorkerManager
)
func init() {
taskman.RegisterTask(CloudproviderSyncResourcesTask{})
CloudproviderSyncWorkerManager = appsrv.NewWorkerManager("CloudproviderSyncWorkerManager", 10, 1024, false)
taskman.RegisterTaskAndWorker(CloudproviderSyncResourcesTask{}, CloudproviderSyncWorkerManager)
}
func (self *CloudproviderSyncResourcesTask) taskFailed(ctx context.Context, cp *models.SCloudprovider, err error) {