in if/py/gen-py/fbnet/command_runner_asyncio/CommandRunner/Command.py [0:0]
def recv_run(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 = run_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
if result.ude != None:
fut.set_exception(result.ude)
return
fut.set_exception(TApplicationException(TApplicationException.MISSING_RESULT, "run failed: unknown result"))
return