diff options
Diffstat (limited to 'share')
| -rw-r--r-- | share/common/msapi/helper.py | 5 | ||||
| -rw-r--r-- | share/starlingx_base/registration/registration.py | 7 |
2 files changed, 10 insertions, 2 deletions
diff --git a/share/common/msapi/helper.py b/share/common/msapi/helper.py index c151d253..50ef3407 100644 --- a/share/common/msapi/helper.py +++ b/share/common/msapi/helper.py @@ -354,6 +354,7 @@ class MultiCloudThreadHelper(object): "id": item["id"], "status": item["status"] } + cache_item_for_query_str = json.dumps(cache_item_for_query) if item.get("repeat", 0) == 0: self.owner.expire(backlog_id) # keep only the id and status @@ -361,7 +362,7 @@ class MultiCloudThreadHelper(object): #update cache try: - cache.set(self.owner.cache_expired_prefix + cache_item_for_query["id"], cache_item_for_query, 3600*24) + cache.set(self.owner.cache_expired_prefix + cache_item_for_query["id"], cache_item_for_query_str, 3600*24) cache.delete(self.owner.cache_prefix + cache_item_for_query["id"]) except Exception as e: logger.error(str(e)) @@ -369,7 +370,7 @@ class MultiCloudThreadHelper(object): item["timestamp"] = now #update cache try: - cache.set(self.owner.cache_prefix + cache_item_for_query["id"], cache_item_for_query, 3600*24) + cache.set(self.owner.cache_prefix + cache_item_for_query["id"], cache_item_for_query_str, 3600*24) except Exception as e: logger.error(str(e)) pass diff --git a/share/starlingx_base/registration/registration.py b/share/starlingx_base/registration/registration.py index da05426f..c795e524 100644 --- a/share/starlingx_base/registration/registration.py +++ b/share/starlingx_base/registration/registration.py @@ -83,6 +83,13 @@ class APIv1Registry(newton_registration.Registry): super(APIv1Registry, self).__init__() # self._logger = logger + def get(self, request, cloud_owner="", cloud_region_id=""): + self._logger.debug("get cloud region: %s, %s" + % (cloud_owner, cloud_region_id)) + + vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id) + return super(APIv1Registry, self).get(request, vimid) + def post(self, request, cloud_owner="", cloud_region_id=""): self._logger.info("registration with : %s, %s" % (cloud_owner, cloud_region_id)) |