in cwl-workflows/apache/airavata/model/process/ttypes.py [0:0]
def write(self, oprot):
if oprot._fast_encode is not None and self.thrift_spec is not None:
oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('ProcessModel')
if self.processId is not None:
oprot.writeFieldBegin('processId', TType.STRING, 1)
oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
oprot.writeFieldEnd()
if self.experimentId is not None:
oprot.writeFieldBegin('experimentId', TType.STRING, 2)
oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
oprot.writeFieldEnd()
if self.creationTime is not None:
oprot.writeFieldBegin('creationTime', TType.I64, 3)
oprot.writeI64(self.creationTime)
oprot.writeFieldEnd()
if self.lastUpdateTime is not None:
oprot.writeFieldBegin('lastUpdateTime', TType.I64, 4)
oprot.writeI64(self.lastUpdateTime)
oprot.writeFieldEnd()
if self.processStatuses is not None:
oprot.writeFieldBegin('processStatuses', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.processStatuses))
for iter36 in self.processStatuses:
iter36.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.processDetail is not None:
oprot.writeFieldBegin('processDetail', TType.STRING, 6)
oprot.writeString(self.processDetail.encode('utf-8') if sys.version_info[0] == 2 else self.processDetail)
oprot.writeFieldEnd()
if self.applicationInterfaceId is not None:
oprot.writeFieldBegin('applicationInterfaceId', TType.STRING, 7)
oprot.writeString(self.applicationInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.applicationInterfaceId)
oprot.writeFieldEnd()
if self.applicationDeploymentId is not None:
oprot.writeFieldBegin('applicationDeploymentId', TType.STRING, 8)
oprot.writeString(self.applicationDeploymentId.encode('utf-8') if sys.version_info[0] == 2 else self.applicationDeploymentId)
oprot.writeFieldEnd()
if self.computeResourceId is not None:
oprot.writeFieldBegin('computeResourceId', TType.STRING, 9)
oprot.writeString(self.computeResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.computeResourceId)
oprot.writeFieldEnd()
if self.processInputs is not None:
oprot.writeFieldBegin('processInputs', TType.LIST, 10)
oprot.writeListBegin(TType.STRUCT, len(self.processInputs))
for iter37 in self.processInputs:
iter37.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.processOutputs is not None:
oprot.writeFieldBegin('processOutputs', TType.LIST, 11)
oprot.writeListBegin(TType.STRUCT, len(self.processOutputs))
for iter38 in self.processOutputs:
iter38.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.processResourceSchedule is not None:
oprot.writeFieldBegin('processResourceSchedule', TType.STRUCT, 12)
self.processResourceSchedule.write(oprot)
oprot.writeFieldEnd()
if self.tasks is not None:
oprot.writeFieldBegin('tasks', TType.LIST, 13)
oprot.writeListBegin(TType.STRUCT, len(self.tasks))
for iter39 in self.tasks:
iter39.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.taskDag is not None:
oprot.writeFieldBegin('taskDag', TType.STRING, 14)
oprot.writeString(self.taskDag.encode('utf-8') if sys.version_info[0] == 2 else self.taskDag)
oprot.writeFieldEnd()
if self.processErrors is not None:
oprot.writeFieldBegin('processErrors', TType.LIST, 15)
oprot.writeListBegin(TType.STRUCT, len(self.processErrors))
for iter40 in self.processErrors:
iter40.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.gatewayExecutionId is not None:
oprot.writeFieldBegin('gatewayExecutionId', TType.STRING, 16)
oprot.writeString(self.gatewayExecutionId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayExecutionId)
oprot.writeFieldEnd()
if self.enableEmailNotification is not None:
oprot.writeFieldBegin('enableEmailNotification', TType.BOOL, 17)
oprot.writeBool(self.enableEmailNotification)
oprot.writeFieldEnd()
if self.emailAddresses is not None:
oprot.writeFieldBegin('emailAddresses', TType.LIST, 18)
oprot.writeListBegin(TType.STRING, len(self.emailAddresses))
for iter41 in self.emailAddresses:
oprot.writeString(iter41.encode('utf-8') if sys.version_info[0] == 2 else iter41)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.storageResourceId is not None:
oprot.writeFieldBegin('storageResourceId', TType.STRING, 19)
oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
oprot.writeFieldEnd()
if self.userDn is not None:
oprot.writeFieldBegin('userDn', TType.STRING, 20)
oprot.writeString(self.userDn.encode('utf-8') if sys.version_info[0] == 2 else self.userDn)
oprot.writeFieldEnd()
if self.generateCert is not None:
oprot.writeFieldBegin('generateCert', TType.BOOL, 21)
oprot.writeBool(self.generateCert)
oprot.writeFieldEnd()
if self.experimentDataDir is not None:
oprot.writeFieldBegin('experimentDataDir', TType.STRING, 22)
oprot.writeString(self.experimentDataDir.encode('utf-8') if sys.version_info[0] == 2 else self.experimentDataDir)
oprot.writeFieldEnd()
if self.userName is not None:
oprot.writeFieldBegin('userName', TType.STRING, 23)
oprot.writeString(self.userName.encode('utf-8') if sys.version_info[0] == 2 else self.userName)
oprot.writeFieldEnd()
if self.useUserCRPref is not None:
oprot.writeFieldBegin('useUserCRPref', TType.BOOL, 24)
oprot.writeBool(self.useUserCRPref)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()