diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py index c34aa0ce..ce1f5a0a 100644 --- a/dask_kubernetes/operator/controller/controller.py +++ b/dask_kubernetes/operator/controller/controller.py @@ -401,7 +401,7 @@ async def handle_scheduler_service_status( assert namespace # If the Service is a LoadBalancer with no ingress endpoints mark the cluster as Pending if spec["type"] == "LoadBalancer" and not len( - status.get("load_balancer", {}).get("ingress", []) + status.get("loadBalancer", {}).get("ingress", []) ): phase = "Pending" # Otherwise mark it as Running diff --git a/dask_kubernetes/operator/networking.py b/dask_kubernetes/operator/networking.py index 1e991640..65d0a464 100644 --- a/dask_kubernetes/operator/networking.py +++ b/dask_kubernetes/operator/networking.py @@ -50,7 +50,7 @@ async def get_external_address_for_scheduler_service( """Take a service object and return the scheduler address.""" if service.spec.type == "LoadBalancer": port = _get_port(service, port_name) - lb = service.status.load_balancer.ingress[0] + lb = service.status.loadBalancer.ingress[0] host = lb.hostname or lb.ip elif service.spec.type == "NodePort": port = _get_port(service, port_name, is_node_port=True)