try:
xact_info.respond_xpath(rwdts.XactRspCode.ACK)
except rift.tasklets.dts.ResponseError as e:
- self._log.error("Reg handle is None during action {} for {}: {}".
- format(action, self.__class__, e))
+ self._log.warning("Reg handle is None during action {} for {}: {}".
+ format(action, self.__class__, e))
reg_event = asyncio.Event(loop=self.loop)
try:
xact_info.respond_xpath(rwdts.XactRspCode.ACK)
except rift.tasklets.dts.ResponseError as e:
- self._log.error(
+ self._log.warning(
"Subscriber DTS prepare for project {}, action {} in class {} failed: {}".
format(self.project, xact_info.query_action, self.__class__, e))
try:
xact_info.respond_xpath(rwdts.XactRspCode.ACK)
except rift.tasklets.dts.ResponseError as e:
- self._log.error(
+ self._log.warning(
"VnfdDtsHandler in project {} with path {} for action {} failed: {}".
format(self._project, xpath, xact_info.query_action, e))
try:
xact_info.respond_xpath(rwdts.XactRspCode.ACK)
except rift.tasklets.dts.ResponseError as e:
- self._log.error(
+ self._log.warning(
"VnfdDtsHandler in project {} with path {} for action {} failed: {}".
format(self._vnfm._project, xpath, xact_info.query_action, e))
@property
def vnfr_vdu_console_xpath(self):
""" path for resource-mgr"""
- return self._project.add_project("D,/rw-vnfr:vnfr-console/rw-vnfr:vnfr[rw-vnfr:id='{}']" +
- "/rw-vnfr:vdur[vnfr:id='{}']".format(self._vnfr_id,self._vdur_id))
+ return self._project.add_project(
+ "D,/rw-vnfr:vnfr-console/rw-vnfr:vnfr[rw-vnfr:id='{}']".format(self._vnfr_id) +
+ "/rw-vnfr:vdur[vnfr:id='{}']".format(self._vdur_id))
def __init__(self, dts, log, loop, vnfm, vnfr_id, vdur_id, vdu_id):
self._dts = dts