Merge pull request #10 from jeronimoalbi/develop

Update to 1.0.0-alpha.8

katana/__init__.py

@@ -1 +1 @@
-__version__ = '1.0.0-alpha.7'
+__version__ = '1.0.0-alpha.8'

katana/worker.py

@@ -142,6 +142,9 @@ def process_payload(self, payload):
             else:
                 # Call callback asynchronusly
                 component = yield from self.callback(component)
+        except CancelledError:
+            # Avoid logging task cancel errors by catching it here.
+            raise
         except Exception as exc:
             LOG.exception('Component failed')
             payload = self.create_error_payload(
@@ -186,6 +189,9 @@ def process_stream(self, stream):
         # Process command and return payload response serialized
         try:
             payload = yield from self.process_payload(payload)
+        except CancelledError:
+            # Avoid logging task cancel errors by catching it here
+            raise
         except HTTPError as err:
             payload = ErrorPayload.new(
                 status=err.status,