Merge pull request #12 from jeronimoalbi/develop

Update to 1.0.0-alpha.10

katana/__init__.py

@@ -1 +1 @@
-__version__ = '1.0.0-alpha.9'
+__version__ = '1.0.0-alpha.10'

katana/service/worker.py

@@ -5,17 +5,10 @@
 from ..payload import Payload
 from ..payload import TransportPayload
 from ..worker import ComponentWorker
+from ..worker import SERVICE_CALL
 
 LOG = logging.getLogger(__name__)
 
-# Constants for response meta frame
-SE = SERVICE_CALL = b'\x01'
-FI = FILES = b'\x02'
-TR = TRANSACTIONS = b'\x03'
-
-# Allowed response meta values
-META_VALUES = (SE, FI, TR)
-
 
 class ServiceWorker(ComponentWorker):
     """Service worker task class."""

katana/worker.py

@@ -17,6 +17,15 @@
 
 LOG = logging.getLogger(__name__)
 
+# Constants for response meta frame
+EMPTY_META = b'\x00'
+SE = SERVICE_CALL = b'\x01'
+FI = FILES = b'\x02'
+TR = TRANSACTIONS = b'\x03'
+
+# Allowed response meta values
+META_VALUES = (EMPTY_META, SE, FI, TR)
+
 
 class ComponentWorker(object):
     """Component worker task class.
@@ -201,7 +210,10 @@ def process_stream(self, stream):
             LOG.exception('Component failed')
             payload = ErrorPayload.new().entity()
 
-        return [self.get_response_meta(payload), serialization.pack(payload)]
+        return [
+            self.get_response_meta(payload) or EMPTY_META,
+            serialization.pack(payload),
+            ]
 
     @asyncio.coroutine
     def _start_handling_requests(self):