未验证 提交 12317a01 编写于 作者: C Colleen Murphy 提交者: GitHub

Merge pull request #32133 from cmurphy/fix-condition-set-master

Do not set unknown condition for creating cluster
...@@ -147,7 +147,7 @@ func (e *OperatorController) SetUnknown(cluster *mgmtv3.Cluster, condition condi ...@@ -147,7 +147,7 @@ func (e *OperatorController) SetUnknown(cluster *mgmtv3.Cluster, condition condi
var err error var err error
cluster, err = e.ClusterClient.Update(cluster) cluster, err = e.ClusterClient.Update(cluster)
if err != nil { if err != nil {
return cluster, fmt.Errorf("failed setting cluster [%s] condition %s unknown with message: %s", cluster.Name, condition, message) return cluster, err
} }
return cluster, nil return cluster, nil
} }
...@@ -162,7 +162,7 @@ func (e *OperatorController) SetTrue(cluster *mgmtv3.Cluster, condition conditio ...@@ -162,7 +162,7 @@ func (e *OperatorController) SetTrue(cluster *mgmtv3.Cluster, condition conditio
var err error var err error
cluster, err = e.ClusterClient.Update(cluster) cluster, err = e.ClusterClient.Update(cluster)
if err != nil { if err != nil {
return cluster, fmt.Errorf("failed setting cluster [%s] condition %s true with message: %s", cluster.Name, condition, message) return cluster, err
} }
return cluster, nil return cluster, nil
} }
...@@ -177,7 +177,7 @@ func (e *OperatorController) SetFalse(cluster *mgmtv3.Cluster, condition conditi ...@@ -177,7 +177,7 @@ func (e *OperatorController) SetFalse(cluster *mgmtv3.Cluster, condition conditi
var err error var err error
cluster, err = e.ClusterClient.Update(cluster) cluster, err = e.ClusterClient.Update(cluster)
if err != nil { if err != nil {
return cluster, fmt.Errorf("failed setting cluster [%s] condition %s false with message: %s", cluster.Name, condition, message) return cluster, err
} }
return cluster, nil return cluster, nil
} }
......
...@@ -160,12 +160,6 @@ func (e *eksOperatorController) onClusterChange(key string, cluster *mgmtv3.Clus ...@@ -160,12 +160,6 @@ func (e *eksOperatorController) onClusterChange(key string, cluster *mgmtv3.Clus
} }
switch phase { switch phase {
case "creating": case "creating":
// set provisioning to unknown
cluster, err = e.SetUnknown(cluster, apimgmtv3.ClusterConditionProvisioned, "")
if err != nil {
return cluster, err
}
if cluster.Status.EKSStatus.UpstreamSpec == nil { if cluster.Status.EKSStatus.UpstreamSpec == nil {
cluster, err = e.setInitialUpstreamSpec(cluster) cluster, err = e.setInitialUpstreamSpec(cluster)
if err != nil { if err != nil {
......
...@@ -153,12 +153,6 @@ func (e *gkeOperatorController) onClusterChange(key string, cluster *mgmtv3.Clus ...@@ -153,12 +153,6 @@ func (e *gkeOperatorController) onClusterChange(key string, cluster *mgmtv3.Clus
switch phase { switch phase {
case "creating": case "creating":
// set provisioning to unknown
cluster, err = e.SetUnknown(cluster, apimgmtv3.ClusterConditionProvisioned, "")
if err != nil {
return cluster, err
}
if cluster.Status.GKEStatus.UpstreamSpec == nil { if cluster.Status.GKEStatus.UpstreamSpec == nil {
cluster, err = e.setInitialUpstreamSpec(cluster) cluster, err = e.setInitialUpstreamSpec(cluster)
if err != nil { if err != nil {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册