summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--share/common/msapi/helper.py5
-rw-r--r--share/starlingx_base/registration/registration.py7
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))