def write()

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

  def write(self, oprot):
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
      return
    oprot.writeStructBegin('TaskConfig')
    if self.isService is not None:
      oprot.writeFieldBegin('isService', TType.BOOL, 7)
      oprot.writeBool(self.isService)
      oprot.writeFieldEnd()
    if self.numCpus is not None:
      oprot.writeFieldBegin('numCpus', TType.DOUBLE, 8)
      oprot.writeDouble(self.numCpus)
      oprot.writeFieldEnd()
    if self.ramMb is not None:
      oprot.writeFieldBegin('ramMb', TType.I64, 9)
      oprot.writeI64(self.ramMb)
      oprot.writeFieldEnd()
    if self.diskMb is not None:
      oprot.writeFieldBegin('diskMb', TType.I64, 10)
      oprot.writeI64(self.diskMb)
      oprot.writeFieldEnd()
    if self.priority is not None:
      oprot.writeFieldBegin('priority', TType.I32, 11)
      oprot.writeI32(self.priority)
      oprot.writeFieldEnd()
    if self.maxTaskFailures is not None:
      oprot.writeFieldBegin('maxTaskFailures', TType.I32, 13)
      oprot.writeI32(self.maxTaskFailures)
      oprot.writeFieldEnd()
    if self.owner is not None:
      oprot.writeFieldBegin('owner', TType.STRUCT, 17)
      self.owner.write(oprot)
      oprot.writeFieldEnd()
    if self.production is not None:
      oprot.writeFieldBegin('production', TType.BOOL, 18)
      oprot.writeBool(self.production)
      oprot.writeFieldEnd()
    if self.constraints is not None:
      oprot.writeFieldBegin('constraints', TType.SET, 20)
      oprot.writeSetBegin(TType.STRUCT, len(self.constraints))
      for iter72 in self.constraints:
        iter72.write(oprot)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.requestedPorts is not None:
      oprot.writeFieldBegin('requestedPorts', TType.SET, 21)
      oprot.writeSetBegin(TType.STRING, len(self.requestedPorts))
      for iter73 in self.requestedPorts:
        oprot.writeString(iter73.encode('utf-8'))
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.taskLinks is not None:
      oprot.writeFieldBegin('taskLinks', TType.MAP, 22)
      oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.taskLinks))
      for kiter74,viter75 in self.taskLinks.items():
        oprot.writeString(kiter74.encode('utf-8'))
        oprot.writeString(viter75.encode('utf-8'))
      oprot.writeMapEnd()
      oprot.writeFieldEnd()
    if self.contactEmail is not None:
      oprot.writeFieldBegin('contactEmail', TType.STRING, 23)
      oprot.writeString(self.contactEmail.encode('utf-8'))
      oprot.writeFieldEnd()
    if self.executorConfig is not None:
      oprot.writeFieldBegin('executorConfig', TType.STRUCT, 25)
      self.executorConfig.write(oprot)
      oprot.writeFieldEnd()
    if self.metadata is not None:
      oprot.writeFieldBegin('metadata', TType.SET, 27)
      oprot.writeSetBegin(TType.STRUCT, len(self.metadata))
      for iter76 in self.metadata:
        iter76.write(oprot)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.job is not None:
      oprot.writeFieldBegin('job', TType.STRUCT, 28)
      self.job.write(oprot)
      oprot.writeFieldEnd()
    if self.container is not None:
      oprot.writeFieldBegin('container', TType.STRUCT, 29)
      self.container.write(oprot)
      oprot.writeFieldEnd()
    if self.tier is not None:
      oprot.writeFieldBegin('tier', TType.STRING, 30)
      oprot.writeString(self.tier.encode('utf-8'))
      oprot.writeFieldEnd()
    if self.resources is not None:
      oprot.writeFieldBegin('resources', TType.SET, 32)
      oprot.writeSetBegin(TType.STRUCT, len(self.resources))
      for iter77 in self.resources:
        iter77.write(oprot)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.mesosFetcherUris is not None:
      oprot.writeFieldBegin('mesosFetcherUris', TType.SET, 33)
      oprot.writeSetBegin(TType.STRUCT, len(self.mesosFetcherUris))
      for iter78 in self.mesosFetcherUris:
        iter78.write(oprot)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    oprot.writeFieldStop()
    oprot.writeStructEnd()