1
1
package cmd
2
2
3
3
import (
4
- "fmt"
5
- "os"
6
4
"time"
7
5
8
6
kapi "k8s.io/kubernetes/pkg/api"
@@ -11,7 +9,6 @@ import (
11
9
"k8s.io/kubernetes/pkg/util/wait"
12
10
13
11
"github.com/openshift/origin/pkg/client"
14
- deployapi "github.com/openshift/origin/pkg/deploy/api"
15
12
"github.com/openshift/origin/pkg/deploy/util"
16
13
)
17
14
@@ -61,17 +58,13 @@ func (scaler *DeploymentConfigScaler) Scale(namespace, name string, newSize uint
61
58
// ScaleSimple does a simple one-shot attempt at scaling - not useful on its
62
59
// own, but a necessary building block for Scale
63
60
func (scaler * DeploymentConfigScaler ) ScaleSimple (namespace , name string , preconditions * kubectl.ScalePrecondition , newSize uint ) error {
64
- dc , err := scaler .dcClient .DeploymentConfigs (namespace ).Get (name )
61
+ scale , err := scaler .dcClient .DeploymentConfigs (namespace ).GetScale (name )
65
62
if err != nil {
66
63
return err
67
64
}
68
- if dc .Spec .Test {
69
- fmt .Fprintln (os .Stderr , "Replica size for a test deployment applies only when the deployment is running." )
70
- }
71
- scale := deployapi .ScaleFromConfig (dc )
72
65
scale .Spec .Replicas = int32 (newSize )
73
66
if _ , err := scaler .dcClient .DeploymentConfigs (namespace ).UpdateScale (scale ); err != nil {
74
- return kubectl.ScaleError {FailureType : kubectl .ScaleUpdateFailure , ResourceVersion : dc . ResourceVersion , ActualError : err }
67
+ return kubectl.ScaleError {FailureType : kubectl .ScaleUpdateFailure , ResourceVersion : "Unknown" , ActualError : err }
75
68
}
76
69
return nil
77
70
}
0 commit comments