Improve retire_worker fallback by using deployments instead of pods (#912)

RossmacD · web-flow · commit 46350db5b98c · 2024-10-25T14:21:42.000+01:00
diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py
@@ -488,7 +488,7 @@ async def retire_workers(
         "This can result in lost data, see https://kubernetes.dask.org/en/latest/operator_troubleshooting.html."
     )
     workers = await kr8s.asyncio.get(
-        "pods",
+        "deployments",
         namespace=namespace,
         label_selector={"dask.org/workergroup-name": worker_group_name},
     )

Original file line number	Diff line number	Diff line change
`@@ -488,7 +488,7 @@ async def retire_workers(`
`488`	`488`	`"This can result in lost data, see https://kubernetes.dask.org/en/latest/operator_troubleshooting.html."`
`489`	`489`	`)`
`490`	`490`	`workers = await kr8s.asyncio.get(`
`491`		`- "pods",`
	`491`	`+ "deployments",`
`492`	`492`	`namespace=namespace,`
`493`	`493`	`label_selector={"dask.org/workergroup-name": worker_group_name},`
`494`	`494`	`)`