Fix: KeyError on Building Scheduler Name in Replica Count Decrease (#872

)
dask · Mar 4, 2024 · b668cc6 · b668cc6
1 parent 1efdc51
commit b668cc6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py
@@ -609,7 +609,9 @@ async def daskworkergroup_replica_update(
         if workers_needed < 0:
             worker_ids = await retire_workers(
                 n_workers=-workers_needed,
-                scheduler_service_name=SCHEDULER_NAME_TEMPLATE.format(cluster_name),
+                scheduler_service_name=SCHEDULER_NAME_TEMPLATE.format(
+                    cluster_name=cluster_name
+                ),
                 worker_group_name=name,
                 namespace=namespace,
                 logger=logger,