summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--ocata/ocata/vesagent/tasks.py2
-rw-r--r--ocata/ocata/vesagent/vesagent_ctrl.py14
-rw-r--r--ocata/ocata/vesagent/vespublish.py2
3 files changed, 11 insertions, 7 deletions
diff --git a/ocata/ocata/vesagent/tasks.py b/ocata/ocata/vesagent/tasks.py
index 21f1e201..7dfb61da 100644
--- a/ocata/ocata/vesagent/tasks.py
+++ b/ocata/ocata/vesagent/tasks.py
@@ -30,7 +30,7 @@ logger = logging.getLogger(__name__)
@app.task(bind=True)
def scheduleBacklogs(self, vimid):
# make sure only one task runs here
- logger.info("schedule with vimid:%" % (vimid))
+ # cannot get vimid ? logger.info("schedule with vimid:%" % (vimid))
logger.debug("scheduleBacklogs starts")
backlog_count, next_time_slot = processBacklogs()
diff --git a/ocata/ocata/vesagent/vesagent_ctrl.py b/ocata/ocata/vesagent/vesagent_ctrl.py
index 43d1ffb7..8e5af243 100644
--- a/ocata/ocata/vesagent/vesagent_ctrl.py
+++ b/ocata/ocata/vesagent/vesagent_ctrl.py
@@ -164,10 +164,15 @@ class VesAgentCtrl(APIView):
self._logger.debug("with META: %s" % request.META)
try:
# get vesagent_config from cloud region
- viminfo = extsys.get_vim_by_id(vimid)
- cloud_extra_info_str = viminfo.get('cloud_extra_info', None)
- cloud_extra_info = json.loads(cloud_extra_info_str) if cloud_extra_info_str is not None else None
- vesagent_config = cloud_extra_info.get("vesagent_config", None) if cloud_extra_info is not None else None
+ try:
+ viminfo = extsys.get_vim_by_id(vimid)
+ cloud_extra_info_str = viminfo.get('cloud_extra_info', '')
+ cloud_extra_info = json.loads(cloud_extra_info_str) if cloud_extra_info_str != '' else None
+ vesagent_config = cloud_extra_info.get("vesagent_config", None) if cloud_extra_info is not None else None
+ except Exception as e:
+ #ignore this error
+ self._logger.warn("cloud extra info is provided with data in bad format: %s" % cloud_extra_info_str)
+ pass
vesagent_backlogs = self.getBacklogsOneVIM(vimid)
@@ -363,7 +368,6 @@ class VesAgentCtrl(APIView):
if VesAgentBacklogsVimListStr is not None:
VesAgentBacklogsVimList = json.loads(VesAgentBacklogsVimListStr)
VesAgentBacklogsVimList = [v for v in VesAgentBacklogsVimList if v != vimid]
- VesAgentBacklogsVimList = self.vimid_
VesAgentBacklogsVimList.append(vimid)
logger.info("VesAgentBacklogs.vimlist is %s" % VesAgentBacklogsVimList)
diff --git a/ocata/ocata/vesagent/vespublish.py b/ocata/ocata/vesagent/vespublish.py
index df77e30b..ab0155c2 100644
--- a/ocata/ocata/vesagent/vespublish.py
+++ b/ocata/ocata/vesagent/vespublish.py
@@ -29,7 +29,7 @@ def publishAnyEventToVES(ves_subscription, event):
if endpoint:
try:
- logger.info("publish event to VES: %s", )
+ logger.info("publish event to VES: %s", endpoint)
headers = {'Content-Type': 'application/json'}
request = urllib2.Request(url=endpoint, headers=headers, data=json.dumps(event))
time.sleep(1)