def write()

in tools/deploy/aurora/api/ttypes.py [0:0]
62 lines of code
19 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('TaskQuery')
    if self.jobName is not None:
      oprot.writeFieldBegin('jobName', TType.STRING, 2)
      oprot.writeString(self.jobName.encode('utf-8'))
      oprot.writeFieldEnd()
    if self.taskIds is not None:
      oprot.writeFieldBegin('taskIds', TType.SET, 4)
      oprot.writeSetBegin(TType.STRING, len(self.taskIds))
      for iter160 in self.taskIds:
        oprot.writeString(iter160.encode('utf-8'))
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.statuses is not None:
      oprot.writeFieldBegin('statuses', TType.SET, 5)
      oprot.writeSetBegin(TType.I32, len(self.statuses))
      for iter161 in self.statuses:
        oprot.writeI32(iter161)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.instanceIds is not None:
      oprot.writeFieldBegin('instanceIds', TType.SET, 7)
      oprot.writeSetBegin(TType.I32, len(self.instanceIds))
      for iter162 in self.instanceIds:
        oprot.writeI32(iter162)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.environment is not None:
      oprot.writeFieldBegin('environment', TType.STRING, 9)
      oprot.writeString(self.environment.encode('utf-8'))
      oprot.writeFieldEnd()
    if self.slaveHosts is not None:
      oprot.writeFieldBegin('slaveHosts', TType.SET, 10)
      oprot.writeSetBegin(TType.STRING, len(self.slaveHosts))
      for iter163 in self.slaveHosts:
        oprot.writeString(iter163.encode('utf-8'))
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.jobKeys is not None:
      oprot.writeFieldBegin('jobKeys', TType.SET, 11)
      oprot.writeSetBegin(TType.STRUCT, len(self.jobKeys))
      for iter164 in self.jobKeys:
        iter164.write(oprot)
      oprot.writeSetEnd()
      oprot.writeFieldEnd()
    if self.offset is not None:
      oprot.writeFieldBegin('offset', TType.I32, 12)
      oprot.writeI32(self.offset)
      oprot.writeFieldEnd()
    if self.limit is not None:
      oprot.writeFieldBegin('limit', TType.I32, 13)
      oprot.writeI32(self.limit)
      oprot.writeFieldEnd()
    if self.role is not None:
      oprot.writeFieldBegin('role', TType.STRING, 14)
      oprot.writeString(self.role.encode('utf-8'))
      oprot.writeFieldEnd()
    oprot.writeFieldStop()
    oprot.writeStructEnd()