diff --git a/api/etc/pcm.yaml b/api/etc/pcm.yaml index ee51794e..4160b508 100644 --- a/api/etc/pcm.yaml +++ b/api/etc/pcm.yaml @@ -50,7 +50,7 @@ ACRpcConf: # Endpoints: # - 127.0.0.1:8888 NonBlock: true - Timeout: 20000 + Timeout: 50000 #rpc CephRpcConf: diff --git a/api/internal/logic/ai/getcenteroverviewlogic.go b/api/internal/logic/ai/getcenteroverviewlogic.go index bcec6855..f7b72607 100644 --- a/api/internal/logic/ai/getcenteroverviewlogic.go +++ b/api/internal/logic/ai/getcenteroverviewlogic.go @@ -79,7 +79,6 @@ func (l *GetCenterOverviewLogic) GetCenterOverview() (resp *types.CenterOverview case <-time.After(1 * time.Second): return resp, nil } - } func (l *GetCenterOverviewLogic) updateClusterResource(mu *sync.RWMutex, ch chan<- struct{}, list []*types.AdapterInfo) { diff --git a/api/internal/scheduler/database/aiStorage.go b/api/internal/scheduler/database/aiStorage.go index 4fcda695..43492a55 100644 --- a/api/internal/scheduler/database/aiStorage.go +++ b/api/internal/scheduler/database/aiStorage.go @@ -227,7 +227,8 @@ func (s *AiStorage) SaveClusterResources(clusterId string, clusterName string, c } func (s *AiStorage) UpdateClusterResources(clusterResource *models.TClusterResource) error { - tx := s.DbEngin.Model(clusterResource).Updates(clusterResource) + tx := s.DbEngin.Where("cluster_id = ?", clusterResource.ClusterId).Updates(clusterResource) + if tx.Error != nil { return tx.Error }