]> git-server-git.apps.pok.os.sepia.ceph.com Git - remoto.git/commitdiff
avoid Message attribute errors, bump execnet 0.0.6
authorAlfredo Deza <alfredo@deza.pe>
Mon, 14 Oct 2013 20:10:11 +0000 (16:10 -0400)
committerAlfredo Deza <alfredo@deza.pe>
Mon, 14 Oct 2013 20:10:11 +0000 (16:10 -0400)
remoto/lib/execnet/__init__.py
remoto/lib/execnet/gateway_base.py

index 45309e7a811620c22ac997c50b0f18fff7ebce24..2b8a281a3fdfe4e2df24a590e60621500287013f 100644 (file)
@@ -3,7 +3,7 @@ execnet: pure python lib for connecting to local and remote Python Interpreters.
 
 (c) 2012, Holger Krekel and others
 """
-__version__ = '1.1'
+__version__ = '1.1-ad1'
 
 from . import apipkg
 
index f60b65b983c9f41129218df907dde369762bbf27..2313babb7a7d31b6bf979ac4d50317c34abb81a1 100644 (file)
@@ -322,15 +322,16 @@ class Channel(object):
             # the remote channel is already in "deleted" state, nothing to do
             pass
         else:
-            # state transition "opened" --> "deleted"
-            if self._items is None:    # has_callback
-                msgcode = Message.CHANNEL_LAST_MESSAGE
-            else:
-                msgcode = Message.CHANNEL_CLOSE
-            try:
-                self.gateway._send(msgcode, self.id)
-            except (IOError, ValueError): # ignore problems with sending
-                pass
+            if Message is not None:
+                # state transition "opened" --> "deleted"
+                if self._items is None:    # has_callback
+                    msgcode = Message.CHANNEL_LAST_MESSAGE
+                else:
+                    msgcode = Message.CHANNEL_CLOSE
+                try:
+                    self.gateway._send(msgcode, self.id)
+                except (IOError, ValueError): # ignore problems with sending
+                    pass
 
     def _getremoteerror(self):
         try: