Small fixes

dask · Aug 8, 2023 · f9a8da6 · f9a8da6
1 parent 7173f63
commit f9a8da6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py
@@ -767,6 +767,7 @@ async def daskautoscaler_adapt(spec, name, namespace, logger, **kwargs):
                 "dask.org/component": "scheduler",
                 "dask.org/cluster-name": spec["cluster"],
             },
+            namespace=namespace,
         )
         if not await scheduler.ready():
             raise ValueError()

diff --git a/dask_kubernetes/operator/kubecluster/kubecluster.py b/dask_kubernetes/operator/kubecluster/kubecluster.py
@@ -384,7 +384,7 @@ async def _create_cluster(self):
             raise SchedulerStartupError(
                 "Scheduler failed to start.",
                 "Scheduler Pod logs:",
-                scheduler_pod.logs(),
+                await scheduler_pod.logs(),
             ) from e
         self._log("Waiting for scheduler service")
         await wait_for_service(f"{self.name}-scheduler", self.namespace)