Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
Rename func
Browse files Browse the repository at this point in the history
  • Loading branch information
pingsutw committed Aug 12, 2020
1 parent b5a4b87 commit c4cc876
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ func dummyTensorflowCustomObj(workers int32, psReplicas int32, chiefReplicas int
}
}

func dummySparkTaskTemplate(id string, tensorflowCustomObj *plugins.DistributedTensorflowTrainingTask) *core.TaskTemplate {
func dummyTensorflowTaskTemplate(id string, tensorflowCustomObj *plugins.DistributedTensorflowTrainingTask) *core.TaskTemplate {

tfObjJSON, err := utils.MarshalToString(tensorflowCustomObj)
if err != nil {
Expand Down Expand Up @@ -247,7 +247,7 @@ func dummyTensorflowJobResource(tensorflowResourceHandler tensorflowOperatorReso
}

tfObj := dummyTensorflowCustomObj(workers, psReplicas, chiefReplicas)
taskTemplate := dummySparkTaskTemplate("the job", tfObj)
taskTemplate := dummyTensorflowTaskTemplate("the job", tfObj)
resource, err := tensorflowResourceHandler.BuildResource(context.TODO(), dummyTensorflowTaskContext(taskTemplate))
if err != nil {
panic(err)
Expand All @@ -273,7 +273,7 @@ func TestBuildResourceTensorflow(t *testing.T) {
tensorflowResourceHandler := tensorflowOperatorResourceHandler{}

tfObj := dummyTensorflowCustomObj(100, 1,1)
taskTemplate := dummySparkTaskTemplate("the job", tfObj)
taskTemplate := dummyTensorflowTaskTemplate("the job", tfObj)

resource, err := tensorflowResourceHandler.BuildResource(context.TODO(), dummyTensorflowTaskContext(taskTemplate))
assert.NoError(t, err)
Expand Down

0 comments on commit c4cc876

Please sign in to comment.