From a79eedff8d2f32b5191b520f5df6a11d6d5cf860 Mon Sep 17 00:00:00 2001 From: Jian Qiu Date: Tue, 10 Feb 2026 09:03:46 +0800 Subject: [PATCH] fix: guest syncstatus subtask for disk create task (#24295) Co-authored-by: Qiu Jian --- pkg/compute/tasks/disk/disk_create_task.go | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/pkg/compute/tasks/disk/disk_create_task.go b/pkg/compute/tasks/disk/disk_create_task.go index c422d53295..d408fbaef9 100644 --- a/pkg/compute/tasks/disk/disk_create_task.go +++ b/pkg/compute/tasks/disk/disk_create_task.go @@ -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{}) }