Skip to content

Commit

Permalink
More minor tweaks to improve readability
Browse files Browse the repository at this point in the history
  • Loading branch information
jacobtomlinson committed Jul 13, 2023
1 parent 6001104 commit f8cbb6a
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions dask_kubernetes/operator/controller/controller.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit f8cbb6a

Please sign in to comment.