from common.msapi import extsys
from fcaps.vesagent.tasks import scheduleBacklogs
from fcaps.vesagent.event_domain import fault_vm
+from fcaps.vesagent.event_domain import pm_vm
from django.core.cache import cache
try:
if backlog_input["domain"] == "fault" and backlog_input["type"] == "vm":
return fault_vm.buildBacklog_fault_vm(vimid, backlog_input)
+ elif backlog_input["domain"] == "pm" and backlog_input["type"] == "vm":
+ return pm_vm.buildBacklog_pm_vm(vimid, backlog_input)
else:
self._logger.warn("return with failure: unsupported backlog domain:%s, type:%s"
% (backlog_input["domain"], backlog_input["type"] == "vm"))