diff --git a/katana/__init__.py b/katana/__init__.py
index 32cb1d9..4fd36dc 100644
--- a/katana/__init__.py
+++ b/katana/__init__.py
@@ -1 +1 @@
-__version__ = '1.0.0-alpha.7'
+__version__ = '1.0.0-alpha.8'
diff --git a/katana/worker.py b/katana/worker.py
index e970f2c..2e8217b 100644
--- a/katana/worker.py
+++ b/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,