worker = item.get("worker", None)
payload = item.get("payload", None)
try:
- item["status"] = worker(*payload) or 0
+ returncode, item["status"] = worker(*payload) or (0, "Succeed")
except Exception as e:
item["status"] = e.message
cache_item_for_query = {
-# Copyright (c) 2017-2018 Wind River Systems, Inc.
+# Copyright (c) 2017-2019 Wind River Systems, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
backlog_item = {
"id": vimid,
"worker": self.register_helper.unregistryV0,
- "payload": (vimid),
+ "payload": (vimid,), # important to add , at the end
"repeat": 0,
- "status": (1, "The de-registration is on process")
+ "status": (1, "The de-registration is in progress")
}
self.register_thread.add(backlog_item)
if 0 == self.register_thread.state():
self._logger.debug("update cloud region fails %s" % e.message)
try:
- super(RegistryHelper, self).registryV0(vimid, project_idorname)
+ return super(RegistryHelper, self).registryV0(vimid, project_idorname)
except Exception as e:
- self._logger.debug("registryV0 fails %s" % e.message)
+ errmsg = "registryV0 fails %s" % str(e)
+ self._logger.debug(errmsg)
+ return 11, errmsg
- return 0
-
- def unregistry(self, vimid=""):
+ def unregistryV0(self, vimid=""):
'''extend base method'''
- return self.super(RegistryHelper, self).unregistry(vimid)
+ try:
+ return super(RegistryHelper, self).unregistryV0(vimid)
+ except Exception as e:
+ errmsg = "unregistryV0 fails %s" % str(e)
+ self._logger.debug(errmsg)
+ return 11, errmsg
+
+ # return (0, "Succeed")
def _get_ovsdpdk_capabilities(self, extra_specs, viminfo):
'''extend base method'''