Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
Signed-off-by: machichima <[email protected]>
  • Loading branch information
machichima committed Feb 5, 2025
1 parent fee3114 commit a783bdd
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions flyteplugins/go/tasks/plugins/k8s/spark/spark.go
Original file line number Diff line number Diff line change
Expand Up @@ -208,9 +208,9 @@ func createDriverSpec(ctx context.Context, taskCtx pluginsCore.TaskExecutionCont
"Unable to unmarshal driver pod spec [%v], Err: [%v]", driverPod.GetPodSpec(), err.Error())
}

Check warning on line 209 in flyteplugins/go/tasks/plugins/k8s/spark/spark.go

View check run for this annotation

Codecov / codecov/patch

flyteplugins/go/tasks/plugins/k8s/spark/spark.go#L207-L209

Added lines #L207 - L209 were not covered by tests

if driverPod.GetPrimaryContainerName() != "" {
primaryContainerName = driverPod.PrimaryContainerName
}
if driverPod.GetPrimaryContainerName() != "" {
primaryContainerName = driverPod.GetPrimaryContainerName()
}

Check warning on line 213 in flyteplugins/go/tasks/plugins/k8s/spark/spark.go

View check run for this annotation

Codecov / codecov/patch

flyteplugins/go/tasks/plugins/k8s/spark/spark.go#L212-L213

Added lines #L212 - L213 were not covered by tests

podSpec, err = flytek8s.MergePodSpecs(podSpec, customPodSpec, primaryContainerName, "")
if err != nil {
Expand Down Expand Up @@ -259,9 +259,9 @@ func createExecutorSpec(ctx context.Context, taskCtx pluginsCore.TaskExecutionCo
"Unable to unmarshal executor pod spec [%v], Err: [%v]", executorPod.GetPodSpec(), err.Error())
}

Check warning on line 260 in flyteplugins/go/tasks/plugins/k8s/spark/spark.go

View check run for this annotation

Codecov / codecov/patch

flyteplugins/go/tasks/plugins/k8s/spark/spark.go#L258-L260

Added lines #L258 - L260 were not covered by tests

if executorPod.GetPrimaryContainerName() != "" {
primaryContainerName = executorPod.PrimaryContainerName
}
if executorPod.GetPrimaryContainerName() != "" {
primaryContainerName = executorPod.GetPrimaryContainerName()
}

Check warning on line 264 in flyteplugins/go/tasks/plugins/k8s/spark/spark.go

View check run for this annotation

Codecov / codecov/patch

flyteplugins/go/tasks/plugins/k8s/spark/spark.go#L263-L264

Added lines #L263 - L264 were not covered by tests

podSpec, err = flytek8s.MergePodSpecs(podSpec, customPodSpec, primaryContainerName, "")
if err != nil {
Expand Down

0 comments on commit a783bdd

Please sign in to comment.