def recv_open_session()

in if/py/gen-py/fbnet/command_runner_asyncio/CommandRunner/Command.py [0:0]


  def recv_open_session(self, iprot, mtype, rseqid):
    try:
        fut = self._futures.pop(rseqid)
    except KeyError:
        return   # request timed out
    if mtype == TMessageType.EXCEPTION:
      x = TApplicationException()
      x.read(iprot)
      iprot.readMessageEnd()
      fut.set_exception(x)
      return
    result = open_session_result()
    try:
      result.read(iprot)
    except Exception as e:
      fut.set_exception(e)
      return
    iprot.readMessageEnd()
    if result.success != None:
      fut.set_result(result.success)
      return
    if result.se != None:
      fut.set_exception(result.se)
      return
    fut.set_exception(TApplicationException(TApplicationException.MISSING_RESULT, "open_session failed: unknown result"))
    return