diff --git a/flyteplugins/go/tasks/plugins/k8s/dask/dask.go b/flyteplugins/go/tasks/plugins/k8s/dask/dask.go index 610bb7bc56..aa820bce38 100755 --- a/flyteplugins/go/tasks/plugins/k8s/dask/dask.go +++ b/flyteplugins/go/tasks/plugins/k8s/dask/dask.go @@ -247,7 +247,7 @@ func createSchedulerSpec(cluster plugins.DaskScheduler, clusterName string, defa Env: defaults.Env, Ports: []v1.ContainerPort{ { - Name: "comm", + Name: "tcp-comm", ContainerPort: 8786, Protocol: "TCP", }, @@ -268,10 +268,10 @@ func createSchedulerSpec(cluster plugins.DaskScheduler, clusterName string, defa }, Ports: []v1.ServicePort{ { - Name: "comm", + Name: "tcp-comm", Protocol: "TCP", Port: 8786, - TargetPort: intstr.FromString("comm"), + TargetPort: intstr.FromString("tcp-comm"), }, { Name: "dashboard", diff --git a/flyteplugins/go/tasks/plugins/k8s/dask/dask_test.go b/flyteplugins/go/tasks/plugins/k8s/dask/dask_test.go index 054f23c1e2..2eb36ad3b9 100644 --- a/flyteplugins/go/tasks/plugins/k8s/dask/dask_test.go +++ b/flyteplugins/go/tasks/plugins/k8s/dask/dask_test.go @@ -213,7 +213,7 @@ func TestBuildResourceDaskHappyPath(t *testing.T) { schedulerSpec := daskJob.Spec.Cluster.Spec.Scheduler.Spec expectedPorts := []v1.ContainerPort{ { - Name: "comm", + Name: "tcp-comm", ContainerPort: 8786, Protocol: "TCP", }, @@ -240,10 +240,10 @@ func TestBuildResourceDaskHappyPath(t *testing.T) { } expectedSerivcePorts := []v1.ServicePort{ { - Name: "comm", + Name: "tcp-comm", Protocol: "TCP", Port: 8786, - TargetPort: intstr.FromString("comm"), + TargetPort: intstr.FromString("tcp-comm"), }, { Name: "dashboard",