You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/08/07 14:01:10 UTC
[34/51] [abbrv] [partial] airavata git commit: AIRAVATA-2505 Upgrade
Airavata to Thrift 0.10.0
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/constants.py
@@ -1,11 +1,12 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
-
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
+from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/ttypes.py
index 0ae58fe..1dce0d0 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/process/ttypes.py
@@ -1,454 +1,420 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
import apache.airavata.model.commons.ttypes
import apache.airavata.model.application.io.ttypes
import apache.airavata.model.status.ttypes
import apache.airavata.model.task.ttypes
import apache.airavata.model.scheduling.ttypes
-
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-
-class ProcessModel:
- """
- ProcessModel: A structure holding the process details. The infromation is derived based on user provided
- configuration data or system inferred information from scheduling and QoS parameters.
- processDetail:
- A friendly description of the process, usally used to communicate information to users.
+class ProcessModel(object):
+ """
+ ProcessModel: A structure holding the process details. The infromation is derived based on user provided
+ configuration data or system inferred information from scheduling and QoS parameters.
+ processDetail:
+ A friendly description of the process, usally used to communicate information to users.
- Attributes:
- - processId
- - experimentId
- - creationTime
- - lastUpdateTime
- - processStatuses
- - processDetail
- - applicationInterfaceId
- - applicationDeploymentId
- - computeResourceId
- - processInputs
- - processOutputs
- - processResourceSchedule
- - tasks
- - taskDag
- - processErrors
- - gatewayExecutionId
- - enableEmailNotification
- - emailAddresses
- - storageResourceId
- - userDn
- - generateCert
- - experimentDataDir
- - userName
- - useUserCRPref
- """
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'processId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.STRING, 'experimentId', None, None, ), # 2
- (3, TType.I64, 'creationTime', None, None, ), # 3
- (4, TType.I64, 'lastUpdateTime', None, None, ), # 4
- (5, TType.LIST, 'processStatuses', (TType.STRUCT,(apache.airavata.model.status.ttypes.ProcessStatus, apache.airavata.model.status.ttypes.ProcessStatus.thrift_spec)), None, ), # 5
- (6, TType.STRING, 'processDetail', None, None, ), # 6
- (7, TType.STRING, 'applicationInterfaceId', None, None, ), # 7
- (8, TType.STRING, 'applicationDeploymentId', None, None, ), # 8
- (9, TType.STRING, 'computeResourceId', None, None, ), # 9
- (10, TType.LIST, 'processInputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec)), None, ), # 10
- (11, TType.LIST, 'processOutputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 11
- (12, TType.STRUCT, 'processResourceSchedule', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ), # 12
- (13, TType.LIST, 'tasks', (TType.STRUCT,(apache.airavata.model.task.ttypes.TaskModel, apache.airavata.model.task.ttypes.TaskModel.thrift_spec)), None, ), # 13
- (14, TType.STRING, 'taskDag', None, None, ), # 14
- (15, TType.LIST, 'processErrors', (TType.STRUCT,(apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec)), None, ), # 15
- (16, TType.STRING, 'gatewayExecutionId', None, None, ), # 16
- (17, TType.BOOL, 'enableEmailNotification', None, None, ), # 17
- (18, TType.LIST, 'emailAddresses', (TType.STRING,None), None, ), # 18
- (19, TType.STRING, 'storageResourceId', None, None, ), # 19
- (20, TType.STRING, 'userDn', None, None, ), # 20
- (21, TType.BOOL, 'generateCert', None, False, ), # 21
- (22, TType.STRING, 'experimentDataDir', None, None, ), # 22
- (23, TType.STRING, 'userName', None, None, ), # 23
- (24, TType.BOOL, 'useUserCRPref', None, None, ), # 24
- )
- def __init__(self, processId=thrift_spec[1][4], experimentId=None, creationTime=None, lastUpdateTime=None, processStatuses=None, processDetail=None, applicationInterfaceId=None, applicationDeploymentId=None, computeResourceId=None, processInputs=None, processOutputs=None, processResourceSchedule=None, tasks=None, taskDag=None, processErrors=None, gatewayExecutionId=None, enableEmailNotification=None, emailAddresses=None, storageResourceId=None, userDn=None, generateCert=thrift_spec[21][4], experimentDataDir=None, userName=None, useUserCRPref=None,):
- self.processId = processId
- self.experimentId = experimentId
- self.creationTime = creationTime
- self.lastUpdateTime = lastUpdateTime
- self.processStatuses = processStatuses
- self.processDetail = processDetail
- self.applicationInterfaceId = applicationInterfaceId
- self.applicationDeploymentId = applicationDeploymentId
- self.computeResourceId = computeResourceId
- self.processInputs = processInputs
- self.processOutputs = processOutputs
- self.processResourceSchedule = processResourceSchedule
- self.tasks = tasks
- self.taskDag = taskDag
- self.processErrors = processErrors
- self.gatewayExecutionId = gatewayExecutionId
- self.enableEmailNotification = enableEmailNotification
- self.emailAddresses = emailAddresses
- self.storageResourceId = storageResourceId
- self.userDn = userDn
- self.generateCert = generateCert
- self.experimentDataDir = experimentDataDir
- self.userName = userName
- self.useUserCRPref = useUserCRPref
+ Attributes:
+ - processId
+ - experimentId
+ - creationTime
+ - lastUpdateTime
+ - processStatuses
+ - processDetail
+ - applicationInterfaceId
+ - applicationDeploymentId
+ - computeResourceId
+ - processInputs
+ - processOutputs
+ - processResourceSchedule
+ - tasks
+ - taskDag
+ - processErrors
+ - gatewayExecutionId
+ - enableEmailNotification
+ - emailAddresses
+ - storageResourceId
+ - userDn
+ - generateCert
+ - experimentDataDir
+ - userName
+ - useUserCRPref
+ """
- 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 == 1:
- if ftype == TType.STRING:
- self.processId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.experimentId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I64:
- self.lastUpdateTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.LIST:
- self.processStatuses = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = apache.airavata.model.status.ttypes.ProcessStatus()
- _elem5.read(iprot)
- self.processStatuses.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.processDetail = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.applicationInterfaceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.applicationDeploymentId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.STRING:
- self.computeResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.LIST:
- self.processInputs = []
- (_etype9, _size6) = iprot.readListBegin()
- for _i10 in xrange(_size6):
- _elem11 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
- _elem11.read(iprot)
- self.processInputs.append(_elem11)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.LIST:
- self.processOutputs = []
- (_etype15, _size12) = iprot.readListBegin()
- for _i16 in xrange(_size12):
- _elem17 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
- _elem17.read(iprot)
- self.processOutputs.append(_elem17)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.STRUCT:
- self.processResourceSchedule = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel()
- self.processResourceSchedule.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 13:
- if ftype == TType.LIST:
- self.tasks = []
- (_etype21, _size18) = iprot.readListBegin()
- for _i22 in xrange(_size18):
- _elem23 = apache.airavata.model.task.ttypes.TaskModel()
- _elem23.read(iprot)
- self.tasks.append(_elem23)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 14:
- if ftype == TType.STRING:
- self.taskDag = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 15:
- if ftype == TType.LIST:
- self.processErrors = []
- (_etype27, _size24) = iprot.readListBegin()
- for _i28 in xrange(_size24):
- _elem29 = apache.airavata.model.commons.ttypes.ErrorModel()
- _elem29.read(iprot)
- self.processErrors.append(_elem29)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 16:
- if ftype == TType.STRING:
- self.gatewayExecutionId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 17:
- if ftype == TType.BOOL:
- self.enableEmailNotification = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 18:
- if ftype == TType.LIST:
- self.emailAddresses = []
- (_etype33, _size30) = iprot.readListBegin()
- for _i34 in xrange(_size30):
- _elem35 = iprot.readString()
- self.emailAddresses.append(_elem35)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 19:
- if ftype == TType.STRING:
- self.storageResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 20:
- if ftype == TType.STRING:
- self.userDn = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 21:
- if ftype == TType.BOOL:
- self.generateCert = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 22:
- if ftype == TType.STRING:
- self.experimentDataDir = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 23:
- if ftype == TType.STRING:
- self.userName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 24:
- if ftype == TType.BOOL:
- self.useUserCRPref = iprot.readBool()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'processId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
+ (2, TType.STRING, 'experimentId', 'UTF8', None, ), # 2
+ (3, TType.I64, 'creationTime', None, None, ), # 3
+ (4, TType.I64, 'lastUpdateTime', None, None, ), # 4
+ (5, TType.LIST, 'processStatuses', (TType.STRUCT, (apache.airavata.model.status.ttypes.ProcessStatus, apache.airavata.model.status.ttypes.ProcessStatus.thrift_spec), False), None, ), # 5
+ (6, TType.STRING, 'processDetail', 'UTF8', None, ), # 6
+ (7, TType.STRING, 'applicationInterfaceId', 'UTF8', None, ), # 7
+ (8, TType.STRING, 'applicationDeploymentId', 'UTF8', None, ), # 8
+ (9, TType.STRING, 'computeResourceId', 'UTF8', None, ), # 9
+ (10, TType.LIST, 'processInputs', (TType.STRUCT, (apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec), False), None, ), # 10
+ (11, TType.LIST, 'processOutputs', (TType.STRUCT, (apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec), False), None, ), # 11
+ (12, TType.STRUCT, 'processResourceSchedule', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ), # 12
+ (13, TType.LIST, 'tasks', (TType.STRUCT, (apache.airavata.model.task.ttypes.TaskModel, apache.airavata.model.task.ttypes.TaskModel.thrift_spec), False), None, ), # 13
+ (14, TType.STRING, 'taskDag', 'UTF8', None, ), # 14
+ (15, TType.LIST, 'processErrors', (TType.STRUCT, (apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec), False), None, ), # 15
+ (16, TType.STRING, 'gatewayExecutionId', 'UTF8', None, ), # 16
+ (17, TType.BOOL, 'enableEmailNotification', None, None, ), # 17
+ (18, TType.LIST, 'emailAddresses', (TType.STRING, 'UTF8', False), None, ), # 18
+ (19, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 19
+ (20, TType.STRING, 'userDn', 'UTF8', None, ), # 20
+ (21, TType.BOOL, 'generateCert', None, False, ), # 21
+ (22, TType.STRING, 'experimentDataDir', 'UTF8', None, ), # 22
+ (23, TType.STRING, 'userName', 'UTF8', None, ), # 23
+ (24, TType.BOOL, 'useUserCRPref', None, None, ), # 24
+ )
- 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('ProcessModel')
- if self.processId is not None:
- oprot.writeFieldBegin('processId', TType.STRING, 1)
- oprot.writeString(self.processId)
- oprot.writeFieldEnd()
- if self.experimentId is not None:
- oprot.writeFieldBegin('experimentId', TType.STRING, 2)
- oprot.writeString(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)
- oprot.writeFieldEnd()
- if self.applicationInterfaceId is not None:
- oprot.writeFieldBegin('applicationInterfaceId', TType.STRING, 7)
- oprot.writeString(self.applicationInterfaceId)
- oprot.writeFieldEnd()
- if self.applicationDeploymentId is not None:
- oprot.writeFieldBegin('applicationDeploymentId', TType.STRING, 8)
- oprot.writeString(self.applicationDeploymentId)
- oprot.writeFieldEnd()
- if self.computeResourceId is not None:
- oprot.writeFieldBegin('computeResourceId', TType.STRING, 9)
- oprot.writeString(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)
- 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)
- 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)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 19)
- oprot.writeString(self.storageResourceId)
- oprot.writeFieldEnd()
- if self.userDn is not None:
- oprot.writeFieldBegin('userDn', TType.STRING, 20)
- oprot.writeString(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)
- oprot.writeFieldEnd()
- if self.userName is not None:
- oprot.writeFieldBegin('userName', TType.STRING, 23)
- oprot.writeString(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()
+ def __init__(self, processId=thrift_spec[1][4], experimentId=None, creationTime=None, lastUpdateTime=None, processStatuses=None, processDetail=None, applicationInterfaceId=None, applicationDeploymentId=None, computeResourceId=None, processInputs=None, processOutputs=None, processResourceSchedule=None, tasks=None, taskDag=None, processErrors=None, gatewayExecutionId=None, enableEmailNotification=None, emailAddresses=None, storageResourceId=None, userDn=None, generateCert=thrift_spec[21][4], experimentDataDir=None, userName=None, useUserCRPref=None,):
+ self.processId = processId
+ self.experimentId = experimentId
+ self.creationTime = creationTime
+ self.lastUpdateTime = lastUpdateTime
+ self.processStatuses = processStatuses
+ self.processDetail = processDetail
+ self.applicationInterfaceId = applicationInterfaceId
+ self.applicationDeploymentId = applicationDeploymentId
+ self.computeResourceId = computeResourceId
+ self.processInputs = processInputs
+ self.processOutputs = processOutputs
+ self.processResourceSchedule = processResourceSchedule
+ self.tasks = tasks
+ self.taskDag = taskDag
+ self.processErrors = processErrors
+ self.gatewayExecutionId = gatewayExecutionId
+ self.enableEmailNotification = enableEmailNotification
+ self.emailAddresses = emailAddresses
+ self.storageResourceId = storageResourceId
+ self.userDn = userDn
+ self.generateCert = generateCert
+ self.experimentDataDir = experimentDataDir
+ self.userName = userName
+ self.useUserCRPref = useUserCRPref
- def validate(self):
- if self.processId is None:
- raise TProtocol.TProtocolException(message='Required field processId is unset!')
- if self.experimentId is None:
- raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
- return
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.processId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I64:
+ self.creationTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I64:
+ self.lastUpdateTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.LIST:
+ self.processStatuses = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in range(_size0):
+ _elem5 = apache.airavata.model.status.ttypes.ProcessStatus()
+ _elem5.read(iprot)
+ self.processStatuses.append(_elem5)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.processDetail = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.applicationInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.applicationDeploymentId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.computeResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.LIST:
+ self.processInputs = []
+ (_etype9, _size6) = iprot.readListBegin()
+ for _i10 in range(_size6):
+ _elem11 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
+ _elem11.read(iprot)
+ self.processInputs.append(_elem11)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.LIST:
+ self.processOutputs = []
+ (_etype15, _size12) = iprot.readListBegin()
+ for _i16 in range(_size12):
+ _elem17 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem17.read(iprot)
+ self.processOutputs.append(_elem17)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.STRUCT:
+ self.processResourceSchedule = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel()
+ self.processResourceSchedule.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 13:
+ if ftype == TType.LIST:
+ self.tasks = []
+ (_etype21, _size18) = iprot.readListBegin()
+ for _i22 in range(_size18):
+ _elem23 = apache.airavata.model.task.ttypes.TaskModel()
+ _elem23.read(iprot)
+ self.tasks.append(_elem23)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 14:
+ if ftype == TType.STRING:
+ self.taskDag = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 15:
+ if ftype == TType.LIST:
+ self.processErrors = []
+ (_etype27, _size24) = iprot.readListBegin()
+ for _i28 in range(_size24):
+ _elem29 = apache.airavata.model.commons.ttypes.ErrorModel()
+ _elem29.read(iprot)
+ self.processErrors.append(_elem29)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 16:
+ if ftype == TType.STRING:
+ self.gatewayExecutionId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 17:
+ if ftype == TType.BOOL:
+ self.enableEmailNotification = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 18:
+ if ftype == TType.LIST:
+ self.emailAddresses = []
+ (_etype33, _size30) = iprot.readListBegin()
+ for _i34 in range(_size30):
+ _elem35 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.emailAddresses.append(_elem35)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 19:
+ if ftype == TType.STRING:
+ self.storageResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 20:
+ if ftype == TType.STRING:
+ self.userDn = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 21:
+ if ftype == TType.BOOL:
+ self.generateCert = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 22:
+ if ftype == TType.STRING:
+ self.experimentDataDir = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 23:
+ if ftype == TType.STRING:
+ self.userName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 24:
+ if ftype == TType.BOOL:
+ self.useUserCRPref = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+ 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()
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.processId)
- value = (value * 31) ^ hash(self.experimentId)
- value = (value * 31) ^ hash(self.creationTime)
- value = (value * 31) ^ hash(self.lastUpdateTime)
- value = (value * 31) ^ hash(self.processStatuses)
- value = (value * 31) ^ hash(self.processDetail)
- value = (value * 31) ^ hash(self.applicationInterfaceId)
- value = (value * 31) ^ hash(self.applicationDeploymentId)
- value = (value * 31) ^ hash(self.computeResourceId)
- value = (value * 31) ^ hash(self.processInputs)
- value = (value * 31) ^ hash(self.processOutputs)
- value = (value * 31) ^ hash(self.processResourceSchedule)
- value = (value * 31) ^ hash(self.tasks)
- value = (value * 31) ^ hash(self.taskDag)
- value = (value * 31) ^ hash(self.processErrors)
- value = (value * 31) ^ hash(self.gatewayExecutionId)
- value = (value * 31) ^ hash(self.enableEmailNotification)
- value = (value * 31) ^ hash(self.emailAddresses)
- value = (value * 31) ^ hash(self.storageResourceId)
- value = (value * 31) ^ hash(self.userDn)
- value = (value * 31) ^ hash(self.generateCert)
- value = (value * 31) ^ hash(self.experimentDataDir)
- value = (value * 31) ^ hash(self.userName)
- value = (value * 31) ^ hash(self.useUserCRPref)
- return value
+ def validate(self):
+ if self.processId is None:
+ raise TProtocolException(message='Required field processId is unset!')
+ if self.experimentId is None:
+ raise TProtocolException(message='Required field experimentId is unset!')
+ return
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
- def __ne__(self, other):
- return not (self == other)
+ def __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/constants.py
@@ -1,11 +1,12 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
-
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
+from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/ttypes.py
index 6fb231b..fcdae4c 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/scheduling/ttypes.py
@@ -1,230 +1,209 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-class ComputationalResourceSchedulingModel:
- """
- ComputationalResourceSchedulingModel:
-
-
-
- Attributes:
- - resourceHostId
- - totalCPUCount
- - nodeCount
- - numberOfThreads
- - queueName
- - wallTimeLimit
- - totalPhysicalMemory
- - chessisNumber
- - staticWorkingDir
- - overrideLoginUserName
- - overrideScratchLocation
- - overrideAllocationProjectNumber
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'resourceHostId', None, None, ), # 1
- (2, TType.I32, 'totalCPUCount', None, None, ), # 2
- (3, TType.I32, 'nodeCount', None, None, ), # 3
- (4, TType.I32, 'numberOfThreads', None, None, ), # 4
- (5, TType.STRING, 'queueName', None, None, ), # 5
- (6, TType.I32, 'wallTimeLimit', None, None, ), # 6
- (7, TType.I32, 'totalPhysicalMemory', None, None, ), # 7
- (8, TType.STRING, 'chessisNumber', None, None, ), # 8
- (9, TType.STRING, 'staticWorkingDir', None, None, ), # 9
- (10, TType.STRING, 'overrideLoginUserName', None, None, ), # 10
- (11, TType.STRING, 'overrideScratchLocation', None, None, ), # 11
- (12, TType.STRING, 'overrideAllocationProjectNumber', None, None, ), # 12
- )
-
- def __init__(self, resourceHostId=None, totalCPUCount=None, nodeCount=None, numberOfThreads=None, queueName=None, wallTimeLimit=None, totalPhysicalMemory=None, chessisNumber=None, staticWorkingDir=None, overrideLoginUserName=None, overrideScratchLocation=None, overrideAllocationProjectNumber=None,):
- self.resourceHostId = resourceHostId
- self.totalCPUCount = totalCPUCount
- self.nodeCount = nodeCount
- self.numberOfThreads = numberOfThreads
- self.queueName = queueName
- self.wallTimeLimit = wallTimeLimit
- self.totalPhysicalMemory = totalPhysicalMemory
- self.chessisNumber = chessisNumber
- self.staticWorkingDir = staticWorkingDir
- self.overrideLoginUserName = overrideLoginUserName
- self.overrideScratchLocation = overrideScratchLocation
- self.overrideAllocationProjectNumber = overrideAllocationProjectNumber
-
- 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 == 1:
- if ftype == TType.STRING:
- self.resourceHostId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.totalCPUCount = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.nodeCount = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I32:
- self.numberOfThreads = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.queueName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I32:
- self.wallTimeLimit = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.totalPhysicalMemory = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.chessisNumber = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.STRING:
- self.staticWorkingDir = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.STRING:
- self.overrideLoginUserName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.overrideScratchLocation = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.STRING:
- self.overrideAllocationProjectNumber = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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('ComputationalResourceSchedulingModel')
- if self.resourceHostId is not None:
- oprot.writeFieldBegin('resourceHostId', TType.STRING, 1)
- oprot.writeString(self.resourceHostId)
- oprot.writeFieldEnd()
- if self.totalCPUCount is not None:
- oprot.writeFieldBegin('totalCPUCount', TType.I32, 2)
- oprot.writeI32(self.totalCPUCount)
- oprot.writeFieldEnd()
- if self.nodeCount is not None:
- oprot.writeFieldBegin('nodeCount', TType.I32, 3)
- oprot.writeI32(self.nodeCount)
- oprot.writeFieldEnd()
- if self.numberOfThreads is not None:
- oprot.writeFieldBegin('numberOfThreads', TType.I32, 4)
- oprot.writeI32(self.numberOfThreads)
- oprot.writeFieldEnd()
- if self.queueName is not None:
- oprot.writeFieldBegin('queueName', TType.STRING, 5)
- oprot.writeString(self.queueName)
- oprot.writeFieldEnd()
- if self.wallTimeLimit is not None:
- oprot.writeFieldBegin('wallTimeLimit', TType.I32, 6)
- oprot.writeI32(self.wallTimeLimit)
- oprot.writeFieldEnd()
- if self.totalPhysicalMemory is not None:
- oprot.writeFieldBegin('totalPhysicalMemory', TType.I32, 7)
- oprot.writeI32(self.totalPhysicalMemory)
- oprot.writeFieldEnd()
- if self.chessisNumber is not None:
- oprot.writeFieldBegin('chessisNumber', TType.STRING, 8)
- oprot.writeString(self.chessisNumber)
- oprot.writeFieldEnd()
- if self.staticWorkingDir is not None:
- oprot.writeFieldBegin('staticWorkingDir', TType.STRING, 9)
- oprot.writeString(self.staticWorkingDir)
- oprot.writeFieldEnd()
- if self.overrideLoginUserName is not None:
- oprot.writeFieldBegin('overrideLoginUserName', TType.STRING, 10)
- oprot.writeString(self.overrideLoginUserName)
- oprot.writeFieldEnd()
- if self.overrideScratchLocation is not None:
- oprot.writeFieldBegin('overrideScratchLocation', TType.STRING, 11)
- oprot.writeString(self.overrideScratchLocation)
- oprot.writeFieldEnd()
- if self.overrideAllocationProjectNumber is not None:
- oprot.writeFieldBegin('overrideAllocationProjectNumber', TType.STRING, 12)
- oprot.writeString(self.overrideAllocationProjectNumber)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.resourceHostId)
- value = (value * 31) ^ hash(self.totalCPUCount)
- value = (value * 31) ^ hash(self.nodeCount)
- value = (value * 31) ^ hash(self.numberOfThreads)
- value = (value * 31) ^ hash(self.queueName)
- value = (value * 31) ^ hash(self.wallTimeLimit)
- value = (value * 31) ^ hash(self.totalPhysicalMemory)
- value = (value * 31) ^ hash(self.chessisNumber)
- value = (value * 31) ^ hash(self.staticWorkingDir)
- value = (value * 31) ^ hash(self.overrideLoginUserName)
- value = (value * 31) ^ hash(self.overrideScratchLocation)
- value = (value * 31) ^ hash(self.overrideAllocationProjectNumber)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
+class ComputationalResourceSchedulingModel(object):
+ """
+ ComputationalResourceSchedulingModel:
+
+
+
+ Attributes:
+ - resourceHostId
+ - totalCPUCount
+ - nodeCount
+ - numberOfThreads
+ - queueName
+ - wallTimeLimit
+ - totalPhysicalMemory
+ - chessisNumber
+ - staticWorkingDir
+ - overrideLoginUserName
+ - overrideScratchLocation
+ - overrideAllocationProjectNumber
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'resourceHostId', 'UTF8', None, ), # 1
+ (2, TType.I32, 'totalCPUCount', None, None, ), # 2
+ (3, TType.I32, 'nodeCount', None, None, ), # 3
+ (4, TType.I32, 'numberOfThreads', None, None, ), # 4
+ (5, TType.STRING, 'queueName', 'UTF8', None, ), # 5
+ (6, TType.I32, 'wallTimeLimit', None, None, ), # 6
+ (7, TType.I32, 'totalPhysicalMemory', None, None, ), # 7
+ (8, TType.STRING, 'chessisNumber', 'UTF8', None, ), # 8
+ (9, TType.STRING, 'staticWorkingDir', 'UTF8', None, ), # 9
+ (10, TType.STRING, 'overrideLoginUserName', 'UTF8', None, ), # 10
+ (11, TType.STRING, 'overrideScratchLocation', 'UTF8', None, ), # 11
+ (12, TType.STRING, 'overrideAllocationProjectNumber', 'UTF8', None, ), # 12
+ )
+
+ def __init__(self, resourceHostId=None, totalCPUCount=None, nodeCount=None, numberOfThreads=None, queueName=None, wallTimeLimit=None, totalPhysicalMemory=None, chessisNumber=None, staticWorkingDir=None, overrideLoginUserName=None, overrideScratchLocation=None, overrideAllocationProjectNumber=None,):
+ self.resourceHostId = resourceHostId
+ self.totalCPUCount = totalCPUCount
+ self.nodeCount = nodeCount
+ self.numberOfThreads = numberOfThreads
+ self.queueName = queueName
+ self.wallTimeLimit = wallTimeLimit
+ self.totalPhysicalMemory = totalPhysicalMemory
+ self.chessisNumber = chessisNumber
+ self.staticWorkingDir = staticWorkingDir
+ self.overrideLoginUserName = overrideLoginUserName
+ self.overrideScratchLocation = overrideScratchLocation
+ self.overrideAllocationProjectNumber = overrideAllocationProjectNumber
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.resourceHostId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.totalCPUCount = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I32:
+ self.nodeCount = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.numberOfThreads = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.queueName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I32:
+ self.wallTimeLimit = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I32:
+ self.totalPhysicalMemory = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.chessisNumber = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.staticWorkingDir = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.STRING:
+ self.overrideLoginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.STRING:
+ self.overrideScratchLocation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.STRING:
+ self.overrideAllocationProjectNumber = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ 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('ComputationalResourceSchedulingModel')
+ if self.resourceHostId is not None:
+ oprot.writeFieldBegin('resourceHostId', TType.STRING, 1)
+ oprot.writeString(self.resourceHostId.encode('utf-8') if sys.version_info[0] == 2 else self.resourceHostId)
+ oprot.writeFieldEnd()
+ if self.totalCPUCount is not None:
+ oprot.writeFieldBegin('totalCPUCount', TType.I32, 2)
+ oprot.writeI32(self.totalCPUCount)
+ oprot.writeFieldEnd()
+ if self.nodeCount is not None:
+ oprot.writeFieldBegin('nodeCount', TType.I32, 3)
+ oprot.writeI32(self.nodeCount)
+ oprot.writeFieldEnd()
+ if self.numberOfThreads is not None:
+ oprot.writeFieldBegin('numberOfThreads', TType.I32, 4)
+ oprot.writeI32(self.numberOfThreads)
+ oprot.writeFieldEnd()
+ if self.queueName is not None:
+ oprot.writeFieldBegin('queueName', TType.STRING, 5)
+ oprot.writeString(self.queueName.encode('utf-8') if sys.version_info[0] == 2 else self.queueName)
+ oprot.writeFieldEnd()
+ if self.wallTimeLimit is not None:
+ oprot.writeFieldBegin('wallTimeLimit', TType.I32, 6)
+ oprot.writeI32(self.wallTimeLimit)
+ oprot.writeFieldEnd()
+ if self.totalPhysicalMemory is not None:
+ oprot.writeFieldBegin('totalPhysicalMemory', TType.I32, 7)
+ oprot.writeI32(self.totalPhysicalMemory)
+ oprot.writeFieldEnd()
+ if self.chessisNumber is not None:
+ oprot.writeFieldBegin('chessisNumber', TType.STRING, 8)
+ oprot.writeString(self.chessisNumber.encode('utf-8') if sys.version_info[0] == 2 else self.chessisNumber)
+ oprot.writeFieldEnd()
+ if self.staticWorkingDir is not None:
+ oprot.writeFieldBegin('staticWorkingDir', TType.STRING, 9)
+ oprot.writeString(self.staticWorkingDir.encode('utf-8') if sys.version_info[0] == 2 else self.staticWorkingDir)
+ oprot.writeFieldEnd()
+ if self.overrideLoginUserName is not None:
+ oprot.writeFieldBegin('overrideLoginUserName', TType.STRING, 10)
+ oprot.writeString(self.overrideLoginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.overrideLoginUserName)
+ oprot.writeFieldEnd()
+ if self.overrideScratchLocation is not None:
+ oprot.writeFieldBegin('overrideScratchLocation', TType.STRING, 11)
+ oprot.writeString(self.overrideScratchLocation.encode('utf-8') if sys.version_info[0] == 2 else self.overrideScratchLocation)
+ oprot.writeFieldEnd()
+ if self.overrideAllocationProjectNumber is not None:
+ oprot.writeFieldBegin('overrideAllocationProjectNumber', TType.STRING, 12)
+ oprot.writeString(self.overrideAllocationProjectNumber.encode('utf-8') if sys.version_info[0] == 2 else self.overrideAllocationProjectNumber)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/constants.py
@@ -1,11 +1,12 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
-
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
+from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/ttypes.py
index 74c50e7..596f6ed 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/security/ttypes.py
@@ -1,108 +1,97 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
+class AuthzToken(object):
+ """
+ Attributes:
+ - accessToken
+ - claimsMap
+ """
-class AuthzToken:
- """
- Attributes:
- - accessToken
- - claimsMap
- """
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'accessToken', 'UTF8', None, ), # 1
+ (2, TType.MAP, 'claimsMap', (TType.STRING, 'UTF8', TType.STRING, 'UTF8', False), None, ), # 2
+ )
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'accessToken', None, None, ), # 1
- (2, TType.MAP, 'claimsMap', (TType.STRING,None,TType.STRING,None), None, ), # 2
- )
+ def __init__(self, accessToken=None, claimsMap=None,):
+ self.accessToken = accessToken
+ self.claimsMap = claimsMap
- def __init__(self, accessToken=None, claimsMap=None,):
- self.accessToken = accessToken
- self.claimsMap = claimsMap
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.accessToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.MAP:
+ self.claimsMap = {}
+ (_ktype1, _vtype2, _size0) = iprot.readMapBegin()
+ for _i4 in range(_size0):
+ _key5 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ _val6 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.claimsMap[_key5] = _val6
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
- 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 == 1:
- if ftype == TType.STRING:
- self.accessToken = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.MAP:
- self.claimsMap = {}
- (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin()
- for _i4 in xrange(_size0):
- _key5 = iprot.readString()
- _val6 = iprot.readString()
- self.claimsMap[_key5] = _val6
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
+ 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('AuthzToken')
+ if self.accessToken is not None:
+ oprot.writeFieldBegin('accessToken', TType.STRING, 1)
+ oprot.writeString(self.accessToken.encode('utf-8') if sys.version_info[0] == 2 else self.accessToken)
+ oprot.writeFieldEnd()
+ if self.claimsMap is not None:
+ oprot.writeFieldBegin('claimsMap', TType.MAP, 2)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.claimsMap))
+ for kiter7, viter8 in self.claimsMap.items():
+ oprot.writeString(kiter7.encode('utf-8') if sys.version_info[0] == 2 else kiter7)
+ oprot.writeString(viter8.encode('utf-8') if sys.version_info[0] == 2 else viter8)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
- 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('AuthzToken')
- if self.accessToken is not None:
- oprot.writeFieldBegin('accessToken', TType.STRING, 1)
- oprot.writeString(self.accessToken)
- oprot.writeFieldEnd()
- if self.claimsMap is not None:
- oprot.writeFieldBegin('claimsMap', TType.MAP, 2)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.claimsMap))
- for kiter7,viter8 in self.claimsMap.items():
- oprot.writeString(kiter7)
- oprot.writeString(viter8)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
+ def validate(self):
+ if self.accessToken is None:
+ raise TProtocolException(message='Required field accessToken is unset!')
+ return
- def validate(self):
- if self.accessToken is None:
- raise TProtocol.TProtocolException(message='Required field accessToken is unset!')
- return
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.accessToken)
- value = (value * 31) ^ hash(self.claimsMap)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
+ def __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/sharing/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/sharing/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/sharing/constants.py
index 68ebfe8..f4184ce 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/sharing/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/sharing/constants.py
@@ -1,12 +1,13 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
-
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
+from .ttypes import *
DO_NOT_SET_AT_CLIENTS_ID = "DO_NOT_SET_AT_CLIENTS_ID"