Skip to content

Commit

Permalink
Fix node port support (#848) (#849)
Browse files Browse the repository at this point in the history
Co-authored-by: Jacob Tomlinson <jtomlinson@nvidia.com>
  • Loading branch information
dbalabka and jacobtomlinson committed Jan 5, 2024
1 parent aae2688 commit dfeca2b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dask_kubernetes/common/networking.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
]
Expand Down

0 comments on commit dfeca2b

Please sign in to comment.