This commit is contained in:
barnett 2018-05-11 23:00:19 +08:00
commit 796b510aea

View File

@ -97,7 +97,7 @@ func (s *restartTask) RunError(e error) {
} }
func (s *restartTask) BeforeRun() { func (s *restartTask) BeforeRun() {
s.taskManager.statusManager.SetStatus(s.modelTask.ServiceID, "stoping") s.taskManager.statusManager.SetStatus(s.modelTask.ServiceID, status.UPGRADE)
label, err := db.GetManager().TenantServiceLabelDao().GetTenantServiceTypeLabel(s.modelTask.ServiceID) label, err := db.GetManager().TenantServiceLabelDao().GetTenantServiceTypeLabel(s.modelTask.ServiceID)
if err == nil && label != nil { if err == nil && label != nil {
if label.LabelValue == util.StatefulServiceType { if label.LabelValue == util.StatefulServiceType {