def recv_bulk_run_local()

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

• 26 lines of code
• 6 McCabe index (conditional complexity)

  def recv_bulk_run_local(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 = bulk_run_local_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.ioe != None:
      fut.set_exception(result.ioe)
      return
    fut.set_exception(TApplicationException(TApplicationException.MISSING_RESULT, "bulk_run_local failed: unknown result"))
    return