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): azure async task

Browse Source
This commit is contained in:
Qu Xuan
2020-12-19 14:01:00 +08:00
parent 3eb25e6dd1
commit f60c1835d1
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/multicloud/azure/azure.go
+5 -5
View File
@@ -649,7 +649,7 @@ func _jsonRequest(client *autorest.Client, method, domain, path string, body jso
return ""
}
location := locationFunc(header)
if len(location) > 0 && (body == nil || body.IsZero()) {
if len(location) > 0 && (body == nil || body.IsZero() || !body.Contains("id")) {
err = cloudprovider.Wait(time.Second*10, time.Minute*30, func() (bool, error) {
req := httputils.NewJsonRequest(httputils.GET, location, nil)
lae := AzureResponseError{}
@@ -670,7 +670,7 @@ func _jsonRequest(client *autorest.Client, method, domain, path string, body jso
task := struct {
Status string
Properties struct {
Output *jsonutils.JSONObject
Output *jsonutils.JSONDict
}
}{}
_body.Unmarshal(&task)
@@ -685,9 +685,9 @@ func _jsonRequest(client *autorest.Client, method, domain, path string, body jso
case "Succeeded":
log.Debugf("process %s %s Succeeded", method, path)
if task.Properties.Output != nil {
body = *task.Properties.Output
return true, nil
body = task.Properties.Output
}
return true, nil
case "Failed":
return false, fmt.Errorf("%s %s failed", method, path)
default:
@@ -697,7 +697,7 @@ func _jsonRequest(client *autorest.Client, method, domain, path string, body jso
return false, nil
})
if err != nil {
return nil, errors.Wrapf(err, "time out for waiting %s %s")
return nil, errors.Wrapf(err, "time out for waiting %s %s", method, url)
}
}
return body, nil