Skip to content

Commit

Permalink
fixes
Browse files Browse the repository at this point in the history
Signed-off-by: Jeev B <[email protected]>
  • Loading branch information
jeevb committed Nov 21, 2023
1 parent f684b0d commit cfc2f24
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions flyteplugins/go/tasks/plugins/k8s/kfoperators/mpi/mpi_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -339,12 +339,6 @@ func TestBuildResourceMPIForWrongInput(t *testing.T) {
_, err := mpiResourceHandler.BuildResource(context.TODO(), dummyMPITaskContext(taskTemplate, resourceRequirements, nil))
assert.Error(t, err)

mpiObj = dummyMPICustomObj(1, 0, 1)
taskTemplate = dummyMPITaskTemplate(mpiID2, mpiObj)

_, err = mpiResourceHandler.BuildResource(context.TODO(), dummyMPITaskContext(taskTemplate, resourceRequirements, nil))
assert.Error(t, err)

mpiObj = dummyMPICustomObj(1, 1, 1)
taskTemplate = dummyMPITaskTemplate(mpiID2, mpiObj)

Expand Down Expand Up @@ -561,8 +555,8 @@ func TestReplicaCounts(t *testing.T) {
contains []mpiOp.ReplicaType
notContains []mpiOp.ReplicaType
}{
{"NoWorkers", 0, 1, true, nil, nil},
{"NoLaunchers", 1, 0, true, nil, nil},
{"NoWorkers", 1, 0, true, nil, nil},
{"Minimum One Launcher", 0, 1, false, []mpiOp.ReplicaType{kubeflowv1.MPIJobReplicaTypeLauncher, kubeflowv1.MPIJobReplicaTypeWorker}, []mpiOp.ReplicaType{}},
{"Works", 1, 1, false, []mpiOp.ReplicaType{kubeflowv1.MPIJobReplicaTypeLauncher, kubeflowv1.MPIJobReplicaTypeWorker}, []mpiOp.ReplicaType{}},
} {
t.Run(test.name, func(t *testing.T) {
Expand Down

0 comments on commit cfc2f24

Please sign in to comment.