From 8a8d0f90058537df527022da70199819cf1b8663 Mon Sep 17 00:00:00 2001 From: Qu Xuan Date: Mon, 11 May 2020 14:36:02 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E9=81=BF=E5=85=8D=E5=8D=B8=E8=BD=BD?= =?UTF-8?q?=E5=AE=8C=E5=B7=B2=E5=88=A0=E9=99=A4=E7=9A=84=E7=A3=81=E7=9B=98?= =?UTF-8?q?=E5=90=8E=EF=BC=8C=E7=A3=81=E7=9B=98=E7=8A=B6=E6=80=81=E4=B8=BA?= =?UTF-8?q?ready?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/compute/tasks/guest_detach_disk_task.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/compute/tasks/guest_detach_disk_task.go b/pkg/compute/tasks/guest_detach_disk_task.go index f9e38a6bc7..71242b5749 100644 --- a/pkg/compute/tasks/guest_detach_disk_task.go +++ b/pkg/compute/tasks/guest_detach_disk_task.go @@ -99,7 +99,7 @@ func (self *GuestDetachDiskTask) OnDetachDiskComplete(ctx context.Context, guest return } } - disk.SetStatus(self.UserCred, api.DISK_READY, "") + models.StartResourceSyncStatusTask(ctx, self.GetUserCred(), disk, "DiskSyncstatusTask", "") keepDisk := jsonutils.QueryBoolean(self.Params, "keep_disk", true) host := guest.GetHost() purge := false @@ -135,7 +135,7 @@ func (self *GuestDetachDiskTask) OnDetachDiskCompleteFailed(ctx context.Context, } disk := objDisk.(*models.SDisk) db.OpsLog.LogEvent(disk, db.ACT_DETACH, reason.String(), self.UserCred) - disk.SetStatus(self.UserCred, api.DISK_READY, "") + models.StartResourceSyncStatusTask(ctx, self.GetUserCred(), disk, "DiskSyncstatusTask", "") err = guest.AttachDisk(ctx, disk, self.UserCred, driver, cache, mountpoint) if err != nil { log.Warningf("recover attach disk %s(%s) for guest %s(%s) error: %v", disk.Name, disk.Id, guest.Name, guest.Id, err)