From c07a08f9ae9dad6064f674695a7ef3af5d3ba67b Mon Sep 17 00:00:00 2001
From: Stephen Diehl <stephen.m.diehl@gmail.com>
Date: Tue, 3 Jul 2012 11:04:50 -0400
Subject: [PATCH] Backport updated protocol.

---
 zipline/protocol.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/zipline/protocol.py b/zipline/protocol.py
index 7081291f..fd786886 100644
--- a/zipline/protocol.py
+++ b/zipline/protocol.py
@@ -140,11 +140,12 @@ CONTROL_PROTOCOL = Enum(
     'HEARTBEAT' , # 0 - req
     'SHUTDOWN'  , # 1 - req
     'KILL'      , # 2 - req
+    'GO'        , #   - req
 
     'OK'        , # 3 - rep
     'DONE'      , # 4 - rep
     'EXCEPTION' , # 5 - rep
-    'SIGNAL'    , # 6 - rep
+    'READY'     , # 6 - rep
 )
 
 def CONTROL_FRAME(event, payload):
@@ -304,7 +305,7 @@ def FEED_FRAME(event):
         - source_id
         - type
     """
-    assert isinstance(event, ndict)
+    assert isinstance(event, ndict), 'unknown type %s' % str(event)
     source_id = event.source_id
     ds_type = event.type
     PACK_DATE(event)