X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=common%2Fpython%2Frift%2Fmano%2Fdts%2Fsubscriber%2Fcore.py;h=a2181e852e8970998a4e0f2a3042e092671770fe;hb=b0a3805d0af2a816875101b80683ffbf6785e118;hp=ebd38f97a27141bebe495855d07207a5ba785c15;hpb=f49375710db1acf3cd74c8651d098b7a08e8d0b2;p=osm%2FSO.git diff --git a/common/python/rift/mano/dts/subscriber/core.py b/common/python/rift/mano/dts/subscriber/core.py index ebd38f97..a2181e85 100644 --- a/common/python/rift/mano/dts/subscriber/core.py +++ b/common/python/rift/mano/dts/subscriber/core.py @@ -161,11 +161,6 @@ class AbstractConfigSubscriber(SubscriberDtsHandler): def register(self): """ Register for VNFD configuration""" - if self.reg: - self._log.warning("RPC already registered for project {}". - format(self._project.name)) - return - def on_apply(dts, acg, xact, action, scratch): """Apply the configuration""" is_recovery = xact.xact is None and action == rwdts.AppconfAction.INSTALL @@ -188,6 +183,8 @@ class AbstractConfigSubscriber(SubscriberDtsHandler): @asyncio.coroutine def on_prepare(dts, acg, xact, xact_info, ks_path, msg, scratch): """ on prepare callback """ + self._log.debug("Subscriber DTS prepare for project %s: %s", + self.project, xact_info.query_action) xact_info.respond_xpath(rwdts.XactRspCode.ACK) acg_hdl = rift.tasklets.AppConfGroup.Handler(on_apply=on_apply)