From f8cbb6a1155c8c2f77ed02ddd3c84e64b23adbe2 Mon Sep 17 00:00:00 2001 From: Jacob Tomlinson Date: Thu, 13 Jul 2023 10:38:36 +0100 Subject: [PATCH] More minor tweaks to improve readability --- dask_kubernetes/operator/controller/controller.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py index 60f472251..af8760d86 100644 --- a/dask_kubernetes/operator/controller/controller.py +++ b/dask_kubernetes/operator/controller/controller.py @@ -831,14 +831,12 @@ async def handle_runner_status_change_succeeded(meta, namespace, logger, **kwarg @kopf.on.create("daskautoscaler.kubernetes.dask.org") -async def daskautoscaler_create(name, body, namespace, logger, **kwargs): +async def daskautoscaler_create(body, namespace, logger, **kwargs): """When an autoscaler is created make it a child of the associated cluster for cascade deletion.""" autoscaler = await DaskAutoscaler(body) cluster = await DaskCluster.get(autoscaler.spec.cluster, namespace=namespace) await cluster.adopt(autoscaler) - logger.info( - f"Autoscaler {name} successfully adopted by cluster {autoscaler.spec.cluster}" - ) + logger.info(f"Autoscaler {autoscaler.name} adopted by cluster {cluster.name}") @kopf.timer("daskautoscaler.kubernetes.dask.org", interval=5.0)