From fad56e8785a0bb67f59a5e5b6ff87415bf523601 Mon Sep 17 00:00:00 2001
From: wanyaoqi <d3lx.yq@gmail.com>
Date: Wed, 2 Nov 2022 16:42:17 +0800
Subject: [PATCH] fix(region): implement failed stage:
 OnDiskLiveChangeStorageReadyFailed

---
 pkg/compute/tasks/guest_change_disk_storage_task.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/pkg/compute/tasks/guest_change_disk_storage_task.go b/pkg/compute/tasks/guest_change_disk_storage_task.go
index 5cba7359a3..68aab82c50 100644
--- a/pkg/compute/tasks/guest_change_disk_storage_task.go
+++ b/pkg/compute/tasks/guest_change_disk_storage_task.go
@@ -136,6 +136,14 @@ func (t *GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReady(
 	}
 }
 
+func (t *GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReadyFailed(
+	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
+) {
+	targetDisk, _ := t.GetTargetDisk()
+	targetDisk.SetStatus(t.GetUserCred(), api.DISK_CLONE_FAIL, data.String())
+	t.TaskFailed(ctx, guest, data)
+}
+
 func (t *GuestChangeDiskStorageTask) OnDiskChangeStorageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject) {
 	srcDisk, err := t.GetSourceDisk()
 	if err != nil {