def read()

in tools/deploy/aurora/api/ttypes.py [0:0]
147 lines of code
51 McCabe index (conditional complexity)

  def read(self, iprot):
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
      return
    iprot.readStructBegin()
    while True:
      (fname, ftype, fid) = iprot.readFieldBegin()
      if ftype == TType.STOP:
        break
      if fid == 28:
        if ftype == TType.STRUCT:
          self.job = JobKey()
          self.job.read(iprot)
        else:
          iprot.skip(ftype)
      elif fid == 17:
        if ftype == TType.STRUCT:
          self.owner = Identity()
          self.owner.read(iprot)
        else:
          iprot.skip(ftype)
      elif fid == 7:
        if ftype == TType.BOOL:
          self.isService = iprot.readBool()
        else:
          iprot.skip(ftype)
      elif fid == 8:
        if ftype == TType.DOUBLE:
          self.numCpus = iprot.readDouble()
        else:
          iprot.skip(ftype)
      elif fid == 9:
        if ftype == TType.I64:
          self.ramMb = iprot.readI64()
        else:
          iprot.skip(ftype)
      elif fid == 10:
        if ftype == TType.I64:
          self.diskMb = iprot.readI64()
        else:
          iprot.skip(ftype)
      elif fid == 11:
        if ftype == TType.I32:
          self.priority = iprot.readI32()
        else:
          iprot.skip(ftype)
      elif fid == 13:
        if ftype == TType.I32:
          self.maxTaskFailures = iprot.readI32()
        else:
          iprot.skip(ftype)
      elif fid == 18:
        if ftype == TType.BOOL:
          self.production = iprot.readBool()
        else:
          iprot.skip(ftype)
      elif fid == 30:
        if ftype == TType.STRING:
          self.tier = iprot.readString().decode('utf-8')
        else:
          iprot.skip(ftype)
      elif fid == 32:
        if ftype == TType.SET:
          self.resources = set()
          (_etype38, _size35) = iprot.readSetBegin()
          for _i39 in xrange(_size35):
            _elem40 = Resource()
            _elem40.read(iprot)
            self.resources.add(_elem40)
          iprot.readSetEnd()
        else:
          iprot.skip(ftype)
      elif fid == 20:
        if ftype == TType.SET:
          self.constraints = set()
          (_etype44, _size41) = iprot.readSetBegin()
          for _i45 in xrange(_size41):
            _elem46 = Constraint()
            _elem46.read(iprot)
            self.constraints.add(_elem46)
          iprot.readSetEnd()
        else:
          iprot.skip(ftype)
      elif fid == 21:
        if ftype == TType.SET:
          self.requestedPorts = set()
          (_etype50, _size47) = iprot.readSetBegin()
          for _i51 in xrange(_size47):
            _elem52 = iprot.readString().decode('utf-8')
            self.requestedPorts.add(_elem52)
          iprot.readSetEnd()
        else:
          iprot.skip(ftype)
      elif fid == 33:
        if ftype == TType.SET:
          self.mesosFetcherUris = set()
          (_etype56, _size53) = iprot.readSetBegin()
          for _i57 in xrange(_size53):
            _elem58 = MesosFetcherURI()
            _elem58.read(iprot)
            self.mesosFetcherUris.add(_elem58)
          iprot.readSetEnd()
        else:
          iprot.skip(ftype)
      elif fid == 22:
        if ftype == TType.MAP:
          self.taskLinks = {}
          (_ktype60, _vtype61, _size59 ) = iprot.readMapBegin()
          for _i63 in xrange(_size59):
            _key64 = iprot.readString().decode('utf-8')
            _val65 = iprot.readString().decode('utf-8')
            self.taskLinks[_key64] = _val65
          iprot.readMapEnd()
        else:
          iprot.skip(ftype)
      elif fid == 23:
        if ftype == TType.STRING:
          self.contactEmail = iprot.readString().decode('utf-8')
        else:
          iprot.skip(ftype)
      elif fid == 25:
        if ftype == TType.STRUCT:
          self.executorConfig = ExecutorConfig()
          self.executorConfig.read(iprot)
        else:
          iprot.skip(ftype)
      elif fid == 27:
        if ftype == TType.SET:
          self.metadata = set()
          (_etype69, _size66) = iprot.readSetBegin()
          for _i70 in xrange(_size66):
            _elem71 = Metadata()
            _elem71.read(iprot)
            self.metadata.add(_elem71)
          iprot.readSetEnd()
        else:
          iprot.skip(ftype)
      elif fid == 29:
        if ftype == TType.STRUCT:
          self.container = Container()
          self.container.read(iprot)
        else:
          iprot.skip(ftype)
      else:
        iprot.skip(ftype)
      iprot.readFieldEnd()
    iprot.readStructEnd()