From 33e2d28d9a7d037901de88b7f6ba7c29d2869857 Mon Sep 17 00:00:00 2001 From: Dmitry Balabka Date: Thu, 21 Dec 2023 16:15:44 +0200 Subject: [PATCH] Fix node port support (#848) --- dask_kubernetes/common/networking.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dask_kubernetes/common/networking.py b/dask_kubernetes/common/networking.py index 30dc3ff9f..fbe8f7e8b 100644 --- a/dask_kubernetes/common/networking.py +++ b/dask_kubernetes/common/networking.py @@ -83,7 +83,7 @@ async def get_external_address_for_scheduler_service( def _get_port(service, port_name, is_node_port=False): """NodePort is a special case when we have to use node_port instead of node""" [port] = [ - port.port if not is_node_port else port.node_port + port.port if not is_node_port else port.nodePort for port in service.spec.ports if port.name == service.metadata.name or port.name == port_name ]