Remove old version

Author: edgar-s-silva-alb

--set

@@ -0,0 +1,8 @@
+FROM ghcr.io/dask/dask-kubernetes-operator:2025.1.1
+
+COPY dask_kubernetes .
+
+USER root
+COPY requirements-test.txt .
+
+RUN pip install -r requirements-test.txt

Dockerfile

@@ -376,63 +376,6 @@ async def daskcluster_create_components(
 
     patch.status["phase"] = "Pending"
 
-
-@kopf.on.update("daskcluster.kubernetes.dask.org")
-async def daskcluster_update(
-    spec: kopf.Spec, status: kopf.Status, namespace: str | None, logger: kopf.Logger,path, meta: kopf.Meta,  **__: Any
-):
-    """When the DaskCluster resource is updated update all the components."""
-    assert namespace
-    # Update scheduler deployment
-    scheduler_deployment = await Deployment(
-        SCHEDULER_NAME_TEMPLATE.format(cluster_name=status["clusterName"]), namespace=namespace
-    )
-
-    scheduler_spec = spec.get("scheduler", {})
-    annotations = _get_annotations(meta)
-    labels = _get_labels(meta)
-    if "metadata" in scheduler_spec:
-        if "annotations" in scheduler_spec["metadata"]:
-            annotations.update(**scheduler_spec["metadata"]["annotations"])
-        if "labels" in scheduler_spec["metadata"]:
-            labels.update(**scheduler_spec["metadata"]["labels"])
-
-    data = build_scheduler_deployment_spec(status["clusterName"], scheduler_spec.get("spec"), annotations, labels)
-    if await scheduler_deployment.exists():
-        await scheduler_deployment.patch(data)
-    else:
-        kopf.adopt(data)
-        await scheduler_deployment.create()
-
-    # Update scheduler service
-    scheduler_service = await Service(
-        SCHEDULER_NAME_TEMPLATE.format(cluster_name=status["clusterName"]), namespace=namespace
-    )
-    data = build_scheduler_service_spec(status["clusterName"], scheduler_spec.get("service"), annotations, labels)
-    if await scheduler_service.exists():
-        await scheduler_service.patch(data)
-    else:
-        kopf.adopt(data)
-        await scheduler_service.create()
-
-    # Update default worker group
-    worker_group = await DaskWorkerGroup.get(f"{status['clusterName']}-default", namespace=namespace)
-    worker_spec = spec.get("worker", {})
-    annotations = _get_annotations(cluster.meta)
-    labels = _get_labels(cluster.meta)
-    if "metadata" in worker_spec:
-        if "annotations" in worker_spec["metadata"]:
-            annotations.update(**worker_spec["metadata"]["annotations"])
-        if "labels" in worker_spec["metadata"]:
-            labels.update(**worker_spec["metadata"]["labels"])
-
-    data = build_default_worker_group_spec(status["clusterName"], worker_spec, annotations, labels)
-    if await worker_group.exists():
-        await worker_group.patch(data)
-    else:
-        kopf.adopt(data)
-        await worker_group.create()
-
 @kopf.on.update("daskcluster.kubernetes.dask.org")
 async def daskcluster_update(
     spec: kopf.Spec,