chore: update kr8s to 0.20.7 (#898)

---------

Co-authored-by: Lionel Sambuc <[email protected]>

Author: wesjdj

components/renku_data_services/k8s/clients.py

@@ -18,11 +18,11 @@
 
 from renku_data_services.errors import errors
 from renku_data_services.k8s.client_interfaces import K8sCoreClientInterface, K8sSchedudlingClientInterface
+from renku_data_services.k8s.models import APIObjectInCluster
 
 if TYPE_CHECKING:
     from renku_data_services.k8s.models import (
         GVK,
-        APIObjectInCluster,
         Cluster,
         ClusterId,
         K8sObject,
@@ -253,20 +253,19 @@ async def __list(self, _filter: K8sObjectFilter) -> AsyncIterable[APIObjectInClu
         names = [_filter.name] if _filter.name is not None else []
 
         try:
-            res = await self.__cluster.api.async_get(
+            res = self.__cluster.api.async_get(
                 _filter.gvk.kr8s_kind,
                 *names,
                 label_selector=_filter.label_selector,
                 namespace=_filter.namespace,
             )
+
+            async for r in res:
+                yield APIObjectInCluster(r, self.__cluster.id)
+
         except (kr8s.ServerError, kr8s.APITimeoutError):
             return
 
-        if not isinstance(res, list):
-            res = [res]
-        for r in res:
-            yield self.__cluster.with_api_object(r)
-
     async def __get_api_object(self, meta: K8sObjectFilter) -> APIObjectInCluster | None:
         return await anext(aiter(self.__list(meta)), None)
 
@@ -312,8 +311,7 @@ async def get(self, meta: K8sObjectMeta) -> K8sObject | None:
 
     async def list(self, _filter: K8sObjectFilter) -> AsyncIterable[K8sObject]:
         """List all k8s objects."""
-        results = self.__list(_filter)
-        async for r in results:
+        async for r in self.__list(_filter):
             yield r.to_k8s_object()
 
 

poetry.lock

@@ -79,7 +79,7 @@ cryptography = "^44.0.1"
 kubernetes-asyncio = "^32.0.0"
 marshmallow = "^3.26.1"
 escapism = "^1.0.1"
-kr8s = "^0.18.1"
+kr8s = "^0.20.7"
 python-box = "^7.0.1"
 werkzeug = "^3.1.3"
 toml = "^0.10.2"

projects/k8s_watcher/poetry.lock

@@ -79,7 +79,7 @@ cryptography = "^44.0.1"
 kubernetes-asyncio = "^32.0.0"
 marshmallow = "^3.26.1"
 escapism = "^1.0.1"
-kr8s = "^0.18.1"
+kr8s = "^0.20.7"
 python-box = "^7.0.1"
 werkzeug = "^3.1.3"
 toml = "^0.10.2"

projects/k8s_watcher/pyproject.toml

@@ -79,7 +79,7 @@ cryptography = "^44.0.1"
 kubernetes-asyncio = "^32.0.0"
 marshmallow = "^3.26.1"
 escapism = "^1.0.1"
-kr8s = "^0.18.1"
+kr8s = "^0.20.7"
 python-box="^7.0.1"
 werkzeug = "^3.1.3"
 toml = "^0.10.2"

projects/renku_data_service/poetry.lock

@@ -78,7 +78,7 @@ aiofile = "^3.9.0"
 # Detected incompatible Protobuf Gencode/Runtime versions when loading authzed/api/v1/core.proto: gencode 5.28.2 runtime 5.27.3.
 protobuf = "^5.29.3"
 escapism = "^1.0.1"
-kr8s = "^0.18.1"
+kr8s = "^0.20.7"
 python-box = "^7.0.1"
 marshmallow = "^3.26.1"
 toml = "^0.10.2"