summaryrefslogtreecommitdiffstats
path: root/windriver/titanium_cloud/vesagent/vesagent_ctrl.py
diff options
context:
space:
mode:
authorBin Yang <bin.yang@windriver.com>2018-05-15 07:46:27 +0000
committerBin Yang <bin.yang@windriver.com>2018-05-15 07:46:27 +0000
commit6bda6e9b753e9d900aca898c438bc8b1e7d006e0 (patch)
treee1253d6dee18e5eb36387b98b2ff894535caaac5 /windriver/titanium_cloud/vesagent/vesagent_ctrl.py
parentef5889eb7bfcc007f97d41618d96612d6bc271e2 (diff)
Add the vesagent worker scheduler as celery task
The vesagent configurion logic will trigger the vesagent worker scheduler via celery Change-Id: I2504f2ef2672c25416062f63ffdfc5495b9200b4 Issue-ID: MULTICLOUD-230 Signed-off-by: Bin Yang <bin.yang@windriver.com>
Diffstat (limited to 'windriver/titanium_cloud/vesagent/vesagent_ctrl.py')
-rw-r--r--windriver/titanium_cloud/vesagent/vesagent_ctrl.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/windriver/titanium_cloud/vesagent/vesagent_ctrl.py b/windriver/titanium_cloud/vesagent/vesagent_ctrl.py
index 987a0966..0cc2e9f5 100644
--- a/windriver/titanium_cloud/vesagent/vesagent_ctrl.py
+++ b/windriver/titanium_cloud/vesagent/vesagent_ctrl.py
@@ -22,6 +22,7 @@ from rest_framework.views import APIView
from django.conf import settings
from common.msapi import extsys
+from titanium_cloud.vesagent.tasks import scheduleBacklogs
from titanium_cloud.vesagent.event_domain.fault_vm import buildBacklog_fault_vm
from django.core.cache import cache
@@ -257,6 +258,8 @@ class VesAgentCtrl(APIView):
# cache forever
cache.set("VesAgentBacklogs.config.%s" % vimid, VesAgentBacklogsConfigStr, None)
+ # notify schduler
+ scheduleBacklogs.delay(vimid)
except Exception as e:
self._logger.error("exception:%s" % str(e))
VesAgentBacklogsConfig = {"error":"exception occurs during build backlogs"}