Skip to content

Commit 28afba3

Browse files
committed
Add delay after rescale
1 parent 372a082 commit 28afba3

File tree

4 files changed

+5
-4
lines changed

4 files changed

+5
-4
lines changed

deploy/v2beta1/mpi-operator.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8241,7 +8241,7 @@ spec:
82418241
- args:
82428242
- -alsologtostderr
82438243
- --lock-namespace=mpi-operator
8244-
image: adityapb/mpi-operator:mpi-imm
8244+
image: adityapb/mpi-operator:mpi
82458245
imagePullPolicy: Always
82468246
name: mpi-operator
82478247
serviceAccountName: mpi-operator

examples/v2beta1/charm/charm-0.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ spec:
4646
sizeLimit: 1.5Gi
4747
Worker:
4848
minReplicas: 15
49-
maxReplicas: 31
49+
maxReplicas: 59
5050
template:
5151
spec:
5252
containers:

examples/v2beta1/charm/charm-2.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,8 @@ spec:
4545
medium: Memory
4646
sizeLimit: 1Gi
4747
Worker:
48-
minReplicas: 43
49-
maxReplicas: 43
48+
minReplicas: 31
49+
maxReplicas: 31
5050
template:
5151
spec:
5252
containers:

pkg/controller/mpi_job_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -689,6 +689,7 @@ func signalRescale(ipAddr string, port int32, oldProcs int32, newProcs int32) er
689689
klog.Infof("Error when rescaling")
690690
return err
691691
}
692+
time.Sleep(3 * time.Second)
692693
return nil
693694
}
694695

0 commit comments

Comments
 (0)