X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fresources%2Fomf%2Fnode.py;h=4229f4403d0f5b4c899480cd54da3348a75e792e;hb=09ac796bac9aa2c41c5ad830f404fe128fffb22d;hp=79c04f2026b43f50466fd045266574f04dca5b67;hpb=332038a4a4e7e8c74db87dea003e4c02418175d6;p=nepi.git diff --git a/src/nepi/resources/omf/node.py b/src/nepi/resources/omf/node.py index 79c04f20..4229f440 100644 --- a/src/nepi/resources/omf/node.py +++ b/src/nepi/resources/omf/node.py @@ -19,7 +19,7 @@ # Julien Tribino from nepi.execution.resource import ResourceManager, clsinit_copy, \ - ResourceState, reschedule_delay, failtrap + ResourceState, reschedule_delay from nepi.execution.attribute import Attribute, Flags from nepi.resources.omf.omf_resource import ResourceGateway, OMFResource from nepi.resources.omf.omf_api import OMFAPIFactory @@ -96,8 +96,7 @@ class OMFNode(OMFResource): return False - @failtrap - def deploy(self): + def do_deploy(self): """ Deploy the RM. It means : Send Xmpp Message Using OMF protocol to enroll the node into the experiment. It becomes DEPLOYED after sending messages to enroll the node @@ -125,23 +124,18 @@ class OMFNode(OMFResource): self.error(msg) raise - super(OMFNode, self).deploy() + super(OMFNode, self).do_deploy() - def release(self): - """Clean the RM at the end of the experiment + def do_release(self): + """ Clean the RM at the end of the experiment """ - try: - if self._omf_api : - self._omf_api.release(self.get('hostname')) - - OMFAPIFactory.release_api(self.get('xmppSlice'), - self.get('xmppHost'), self.get('xmppPort'), - self.get('xmppPassword'), exp_id = self.exp_id) - except: - import traceback - err = traceback.format_exc() - self.error(err) - - super(OMFNode, self).release() + if self._omf_api: + self._omf_api.release(self.get('hostname')) + + OMFAPIFactory.release_api(self.get('xmppSlice'), + self.get('xmppHost'), self.get('xmppPort'), + self.get('xmppPassword'), exp_id = self.exp_id) + + super(OMFNode, self).do_release()