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(region):modelartsTimeout

Browse Source
This commit is contained in:
mhf
2022-11-04 15:49:24 +08:00
parent 6984df0233
commit d4b30efc64
3 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/apis/compute/modelarts_pool.go
View File

@@ -29,6 +29,7 @@ const (
MODELARTS_POOL_STATUS_CHANGE_CONFIG_FAILED = "change_config_failed"
MODELARTS_POOL_STATUS_ERROR = "error"
MODELARTS_POOL_STATUS_UNKNOWN = "unknown"
MODELARTS_POOL_STATUS_TIMEOUT = "timeout"
)
type ModelartsPoolCreateInput struct {

5
pkg/compute/tasks/modelarts_pool_change_config_task.go
View File

@@ -65,7 +65,10 @@ func (self *ModelartsPoolChangeConfigTask) OnInit(ctx context.Context, obj db.IS
time.Sleep(30 * time.Second)
err = cloudprovider.WaitMultiStatus(iMp, []string{api.MODELARTS_POOL_STATUS_RUNNING, api.MODELARTS_POOL_STATUS_CHANGE_CONFIG_FAILED}, 15*time.Second, 2*time.Hour)
if err != nil {
self.taskFailed(ctx, pool, errors.Wrapf(err, "WaitStatusWithDelay"))
pool.SetStatus(self.UserCred, api.MODELARTS_POOL_STATUS_TIMEOUT, err.Error())
db.OpsLog.LogEvent(pool, db.ACT_CHANGE_CONFIG, err, self.UserCred)
logclient.AddActionLogWithStartable(self, pool, logclient.ACT_CHANGE_CONFIG, err, self.UserCred, false)
self.SetStageFailed(ctx, jsonutils.NewString(err.Error()))
return
}
pool.SyncWithCloudModelartsPool(ctx, self.GetUserCred(), iMp)

6
pkg/compute/tasks/modelarts_pool_create_task.go
View File

@@ -40,6 +40,7 @@ func init() {
func (self *ModelartsPoolCreateTask) taskFailed(ctx context.Context, pool *models.SModelartsPool, err error) {
pool.SetStatus(self.UserCred, api.MODELARTS_POOL_STATUS_CREATE_FAILED, err.Error())
db.OpsLog.LogEvent(pool, db.ACT_ALLOCATE, err, self.UserCred)
logclient.AddActionLogWithStartable(self, pool, logclient.ACT_ALLOCATE, err, self.UserCred, false)
self.SetStageFailed(ctx, jsonutils.NewString(err.Error()))
}
@@ -74,7 +75,10 @@ func (self *ModelartsPoolCreateTask) OnInit(ctx context.Context, obj db.IStandal
time.Sleep(30 * time.Second)
err = cloudprovider.WaitMultiStatus(ipool, []string{api.MODELARTS_POOL_STATUS_RUNNING, api.MODELARTS_POOL_STATUS_CREATE_FAILED}, 15*time.Second, 2*time.Hour)
if err != nil {
self.taskFailed(ctx, pool, errors.Wrapf(err, "db.WaitStatusWithDelay"))
pool.SetStatus(self.UserCred, api.MODELARTS_POOL_STATUS_TIMEOUT, err.Error())
db.OpsLog.LogEvent(pool, db.ACT_ALLOCATE, err, self.UserCred)
logclient.AddActionLogWithStartable(self, pool, logclient.ACT_ALLOCATE, err, self.UserCred, false)
self.SetStageFailed(ctx, jsonutils.NewString(err.Error()))
return
}
pool.SetStatus(self.GetUserCred(), api.MODELARTS_POOL_STATUS_RUNNING, "")