

def dispatch_reply(self, raw_msg):
    (idents, msg) = self.session.feed_identities()
    try:
        msg = self.session.unpack_message(msg, content=False)
    except:
        print(('bad msg: %s' % msg))
    msgtype = msg['msg_type']
    handler = idents.handlers.get(msgtype, None)
    if (handler is None):
        self.upstream.send_multipart(raw_msg, copy=False)
    else:
        handler(msg)

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/engine/kernelstarter.py KernelStarter.dispatch_reply/VarMisuse@69/92 `self`->`idents`