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

fix(region): snapshot policy unbind disks (#23240)

Browse Source
This commit is contained in:
屈轩
2025-09-04 16:57:38 +08:00
committed by GitHub
parent c37b15a3d0
commit 0c090d08f2
3 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/models/snapshotpolicy.go
+1 -1
View File
@@ -592,7 +592,7 @@ func (sp *SSnapshotPolicy) PerformUnbindDisks(
return nil, err
}
disk := diskObj.(*SDisk)
if utils.IsInStringArray(disk.Id, diskIds) {
if !utils.IsInStringArray(disk.Id, diskIds) {
diskIds = append(diskIds, disk.Id)
}
}
pkg/compute/tasks/snapshotpolicy_bind_disks_task.go
+6
View File
@@ -24,6 +24,7 @@ import (
api "yunion.io/x/onecloud/pkg/apis/compute"
"yunion.io/x/onecloud/pkg/cloudcommon/db"
"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
"yunion.io/x/onecloud/pkg/cloudcommon/notifyclient"
"yunion.io/x/onecloud/pkg/compute/models"
"yunion.io/x/onecloud/pkg/util/logclient"
)
@@ -64,6 +65,11 @@ func (self *SnapshotpolicyBindDisksTask) OnInit(ctx context.Context, obj db.ISta
func (self *SnapshotpolicyBindDisksTask) OnSnapshotPolicyBindDisksComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject) {
sp.SetStatus(ctx, self.UserCred, apis.STATUS_AVAILABLE, "")
notifyclient.EventNotify(ctx, self.UserCred, notifyclient.SEventNotifyParam{
Obj: sp,
Action: notifyclient.ActionExecute,
})
self.SetStageComplete(ctx, nil)
}
pkg/compute/tasks/snapshotpolicy_unbind_disks_task.go
+5
View File
@@ -24,6 +24,7 @@ import (
api "yunion.io/x/onecloud/pkg/apis/compute"
"yunion.io/x/onecloud/pkg/cloudcommon/db"
"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
"yunion.io/x/onecloud/pkg/cloudcommon/notifyclient"
"yunion.io/x/onecloud/pkg/compute/models"
"yunion.io/x/onecloud/pkg/util/logclient"
)
@@ -64,6 +65,10 @@ func (self *SnapshotpolicyUnbindDisksTask) OnInit(ctx context.Context, obj db.IS
func (self *SnapshotpolicyUnbindDisksTask) OnSnapshotPolicyUnbindDisksComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject) {
sp.SetStatus(ctx, self.UserCred, apis.STATUS_AVAILABLE, "")
notifyclient.EventNotify(ctx, self.UserCred, notifyclient.SEventNotifyParam{
Obj: sp,
Action: notifyclient.ActionExecute,
})
self.SetStageComplete(ctx, nil)
}