fanhuadesenlinnn/cloudpods
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/yunionio/cloudpods.git synced 2026-09-20 08:03:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: guest syncstatus subtask for disk create task (#24295)

Browse Source 
Co-authored-by: Qiu Jian <qiujian@yunionyun.com>
This commit is contained in:
Jian Qiu
2026-02-10 09:03:46 +08:00
committed by GitHub
parent 9a88e9afc9
commit a79eedff8d
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/compute/tasks/disk/disk_create_task.go
View File

@@ -139,7 +139,9 @@ func (self *DiskCreateTask) OnDiskReady(ctx context.Context, disk *models.SDisk,
guest := disk.GetGuest()
if guest != nil {
// just sync guest status
guest.StartSyncstatus(ctx, self.GetUserCred(), "")
self.SetStage("OnGuestSyncstatusComplete", nil)
guest.StartSyncstatus(ctx, self.GetUserCred(), self.GetTaskId())
return
}
}
self.SetStageComplete(ctx, nil)
@@ -156,6 +158,16 @@ func (self *DiskCreateTask) OnDiskReadyFailed(ctx context.Context, disk *models.
self.SetStageFailed(ctx, data)
}
func (self *DiskCreateTask) OnGuestSyncstatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject) {
self.SetStageComplete(ctx, nil)
}
func (self *DiskCreateTask) OnGuestSyncstatusCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject) {
// ??? why
log.Errorf("OnGuestSyncstatusCompleteFailed: %s", err.String())
self.SetStageFailed(ctx, err)
}
func init() {
taskman.RegisterTask(DiskCreateTask{})
}