Bumped version

Author: annatisch

HISTORY.rst

@@ -3,7 +3,7 @@
 Release History
 ===============
 
-1.0.3 (unreleased)
+1.0.3 (2018-09-14)
 ++++++++++++++++++
 
 - Reduced CPU load during idle receive.

uamqp/__init__.py

@@ -32,7 +32,7 @@
     pass  # Async not supported.
 
 
-__version__ = "1.0.3a1"
+__version__ = "1.0.3"
 
 
 _logger = logging.getLogger(__name__)

uamqp/async_ops/connection_async.py

@@ -194,7 +194,9 @@ async def destroy_async(self):
             _logger.debug("Unlocked connection %r to close.", self.container_id)
             await self._close_async()
         except asyncio.TimeoutError:
-            _logger.debug("Connection %r timed out while waiting for lock acquisition on destroy. Destroying anyway.", self.container_id)
+            _logger.debug(
+                "Connection %r timed out while waiting for lock acquisition on destroy. Destroying anyway.",
+                self.container_id)
             await self._close_async()
         finally:
             self.release_async()

uamqp/receiver.py

@@ -145,7 +145,8 @@ def _state_changed(self, previous_state, new_state):
             _new_state = constants.MessageReceiverState(new_state)
         except ValueError:
             _new_state = new_state
-        if _previous_state == constants.MessageReceiverState.Opening and _new_state == constants.MessageReceiverState.Error:
+        if _previous_state == constants.MessageReceiverState.Opening \
+                and _new_state == constants.MessageReceiverState.Error:
             _logger.info("Receiver link failed to open - expecting to receive DETACH frame.")
         else:
             self.on_state_changed(_previous_state, _new_state)

uamqp/sender.py

@@ -165,7 +165,8 @@ def _state_changed(self, previous_state, new_state):
             _new_state = constants.MessageSenderState(new_state)
         except ValueError:
             _new_state = new_state
-        if _previous_state == constants.MessageSenderState.Opening and _new_state == constants.MessageSenderState.Error:
+        if _previous_state == constants.MessageSenderState.Opening \
+                and _new_state == constants.MessageSenderState.Error:
             _logger.info("Send link failed to open - expecting to receive DETACH frame.")
         else:
             self.on_state_changed(_previous_state, _new_state)