Loading src/srm/adapters/federation_manager/fm_client.py +3 −3 Original line number Diff line number Diff line Loading @@ -105,7 +105,7 @@ class FederationManager(FederationManagerPort): async def get_zone(self, zone_id: UUID) -> Zone | None: try: res = await self._request("GET", str.format(_GET_ZONE_ENDPOINT, zone_id=zone_id)) return Zone.model_validate_json(res) return Zone.model_validate(res) except NotFoundException: return None Loading @@ -120,7 +120,7 @@ class FederationManager(FederationManagerPort): res = await self._request("GET", _LIST_SERVICE_INSTANCES_ENDPOINT) instances = [] for obj in res: instances.append(ServiceInstance.model_validate_json(obj)) instances.append(ServiceInstance.model_validate(obj)) return instances async def get_service_instance(self, service_instance_id: UUID) -> ServiceInstance: Loading @@ -129,7 +129,7 @@ class FederationManager(FederationManagerPort): str.format(_GET_SERVICE_INSTANCE_ENDPOINT, service_instance_id=service_instance_id), ) return ServiceInstance.model_validate_json(res) return ServiceInstance.model_validate(res) async def request_deploy_service(self, command: dict[str, Any]) -> None: logger.info( Loading Loading
src/srm/adapters/federation_manager/fm_client.py +3 −3 Original line number Diff line number Diff line Loading @@ -105,7 +105,7 @@ class FederationManager(FederationManagerPort): async def get_zone(self, zone_id: UUID) -> Zone | None: try: res = await self._request("GET", str.format(_GET_ZONE_ENDPOINT, zone_id=zone_id)) return Zone.model_validate_json(res) return Zone.model_validate(res) except NotFoundException: return None Loading @@ -120,7 +120,7 @@ class FederationManager(FederationManagerPort): res = await self._request("GET", _LIST_SERVICE_INSTANCES_ENDPOINT) instances = [] for obj in res: instances.append(ServiceInstance.model_validate_json(obj)) instances.append(ServiceInstance.model_validate(obj)) return instances async def get_service_instance(self, service_instance_id: UUID) -> ServiceInstance: Loading @@ -129,7 +129,7 @@ class FederationManager(FederationManagerPort): str.format(_GET_SERVICE_INSTANCE_ENDPOINT, service_instance_id=service_instance_id), ) return ServiceInstance.model_validate_json(res) return ServiceInstance.model_validate(res) async def request_deploy_service(self, command: dict[str, Any]) -> None: logger.info( Loading