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/04 20:10:58 UTC
[41/51] [partial] airavata git commit: AIRAVATA-2505 Upgrade Airavata
to Thrift 0.10.0
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/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/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
index ecb93e8..7e7d4dc 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
@@ -1,564 +1,522 @@
#
-# 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.appcatalog.computeresource.ttypes
import apache.airavata.model.data.movement.ttypes
-
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-
-class ComputeResourcePreference:
- """
- Gateway specific preferences for a Computer Resource
-
- computeResourceId:
- Corelate the preference to a compute resource.
-
- overridebyAiravata:
- If turned true, Airavata will override the preferences of better alternatives exist.
-
- loginUserName:
- If turned true, Airavata will override the preferences of better alternatives exist.
-
- preferredJobSubmissionProtocol:
- For resources with multiple job submission protocols, the gateway can pick a preferred option.
-
- preferredDataMovementProtocol:
- For resources with multiple data movement protocols, the gateway can pick a preferred option.
-
- preferredBatchQueue:
- Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics.
-
- scratchLocation:
- Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution.
-
- allocationProjectNumber:
- Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an
- allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the
- account to be used has to be added to the allocation.
-
- resourceSpecificCredentialStoreToken:
- Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's
- default credential store.
-
-
- Attributes:
- - computeResourceId
- - overridebyAiravata
- - loginUserName
- - preferredJobSubmissionProtocol
- - preferredDataMovementProtocol
- - preferredBatchQueue
- - scratchLocation
- - allocationProjectNumber
- - resourceSpecificCredentialStoreToken
- - usageReportingGatewayId
- - qualityOfService
- - reservation
- - reservationStartTime
- - reservationEndTime
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'computeResourceId', None, None, ), # 1
- (2, TType.BOOL, 'overridebyAiravata', None, True, ), # 2
- (3, TType.STRING, 'loginUserName', None, None, ), # 3
- (4, TType.I32, 'preferredJobSubmissionProtocol', None, None, ), # 4
- (5, TType.I32, 'preferredDataMovementProtocol', None, None, ), # 5
- (6, TType.STRING, 'preferredBatchQueue', None, None, ), # 6
- (7, TType.STRING, 'scratchLocation', None, None, ), # 7
- (8, TType.STRING, 'allocationProjectNumber', None, None, ), # 8
- (9, TType.STRING, 'resourceSpecificCredentialStoreToken', None, None, ), # 9
- (10, TType.STRING, 'usageReportingGatewayId', None, None, ), # 10
- (11, TType.STRING, 'qualityOfService', None, None, ), # 11
- (12, TType.STRING, 'reservation', None, None, ), # 12
- (13, TType.I64, 'reservationStartTime', None, None, ), # 13
- (14, TType.I64, 'reservationEndTime', None, None, ), # 14
- )
-
- def __init__(self, computeResourceId=None, overridebyAiravata=thrift_spec[2][4], loginUserName=None, preferredJobSubmissionProtocol=None, preferredDataMovementProtocol=None, preferredBatchQueue=None, scratchLocation=None, allocationProjectNumber=None, resourceSpecificCredentialStoreToken=None, usageReportingGatewayId=None, qualityOfService=None, reservation=None, reservationStartTime=None, reservationEndTime=None,):
- self.computeResourceId = computeResourceId
- self.overridebyAiravata = overridebyAiravata
- self.loginUserName = loginUserName
- self.preferredJobSubmissionProtocol = preferredJobSubmissionProtocol
- self.preferredDataMovementProtocol = preferredDataMovementProtocol
- self.preferredBatchQueue = preferredBatchQueue
- self.scratchLocation = scratchLocation
- self.allocationProjectNumber = allocationProjectNumber
- self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken
- self.usageReportingGatewayId = usageReportingGatewayId
- self.qualityOfService = qualityOfService
- self.reservation = reservation
- self.reservationStartTime = reservationStartTime
- self.reservationEndTime = reservationEndTime
-
- 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.computeResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.BOOL:
- self.overridebyAiravata = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.loginUserName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I32:
- self.preferredJobSubmissionProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.preferredDataMovementProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.preferredBatchQueue = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.scratchLocation = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.allocationProjectNumber = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.STRING:
- self.resourceSpecificCredentialStoreToken = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.STRING:
- self.usageReportingGatewayId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.qualityOfService = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.STRING:
- self.reservation = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 13:
- if ftype == TType.I64:
- self.reservationStartTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 14:
- if ftype == TType.I64:
- self.reservationEndTime = iprot.readI64()
- 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('ComputeResourcePreference')
- if self.computeResourceId is not None:
- oprot.writeFieldBegin('computeResourceId', TType.STRING, 1)
- oprot.writeString(self.computeResourceId)
- oprot.writeFieldEnd()
- if self.overridebyAiravata is not None:
- oprot.writeFieldBegin('overridebyAiravata', TType.BOOL, 2)
- oprot.writeBool(self.overridebyAiravata)
- oprot.writeFieldEnd()
- if self.loginUserName is not None:
- oprot.writeFieldBegin('loginUserName', TType.STRING, 3)
- oprot.writeString(self.loginUserName)
- oprot.writeFieldEnd()
- if self.preferredJobSubmissionProtocol is not None:
- oprot.writeFieldBegin('preferredJobSubmissionProtocol', TType.I32, 4)
- oprot.writeI32(self.preferredJobSubmissionProtocol)
- oprot.writeFieldEnd()
- if self.preferredDataMovementProtocol is not None:
- oprot.writeFieldBegin('preferredDataMovementProtocol', TType.I32, 5)
- oprot.writeI32(self.preferredDataMovementProtocol)
- oprot.writeFieldEnd()
- if self.preferredBatchQueue is not None:
- oprot.writeFieldBegin('preferredBatchQueue', TType.STRING, 6)
- oprot.writeString(self.preferredBatchQueue)
- oprot.writeFieldEnd()
- if self.scratchLocation is not None:
- oprot.writeFieldBegin('scratchLocation', TType.STRING, 7)
- oprot.writeString(self.scratchLocation)
- oprot.writeFieldEnd()
- if self.allocationProjectNumber is not None:
- oprot.writeFieldBegin('allocationProjectNumber', TType.STRING, 8)
- oprot.writeString(self.allocationProjectNumber)
- oprot.writeFieldEnd()
- if self.resourceSpecificCredentialStoreToken is not None:
- oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 9)
- oprot.writeString(self.resourceSpecificCredentialStoreToken)
- oprot.writeFieldEnd()
- if self.usageReportingGatewayId is not None:
- oprot.writeFieldBegin('usageReportingGatewayId', TType.STRING, 10)
- oprot.writeString(self.usageReportingGatewayId)
- oprot.writeFieldEnd()
- if self.qualityOfService is not None:
- oprot.writeFieldBegin('qualityOfService', TType.STRING, 11)
- oprot.writeString(self.qualityOfService)
- oprot.writeFieldEnd()
- if self.reservation is not None:
- oprot.writeFieldBegin('reservation', TType.STRING, 12)
- oprot.writeString(self.reservation)
- oprot.writeFieldEnd()
- if self.reservationStartTime is not None:
- oprot.writeFieldBegin('reservationStartTime', TType.I64, 13)
- oprot.writeI64(self.reservationStartTime)
- oprot.writeFieldEnd()
- if self.reservationEndTime is not None:
- oprot.writeFieldBegin('reservationEndTime', TType.I64, 14)
- oprot.writeI64(self.reservationEndTime)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.computeResourceId is None:
- raise TProtocol.TProtocolException(message='Required field computeResourceId is unset!')
- if self.overridebyAiravata is None:
- raise TProtocol.TProtocolException(message='Required field overridebyAiravata is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.computeResourceId)
- value = (value * 31) ^ hash(self.overridebyAiravata)
- value = (value * 31) ^ hash(self.loginUserName)
- value = (value * 31) ^ hash(self.preferredJobSubmissionProtocol)
- value = (value * 31) ^ hash(self.preferredDataMovementProtocol)
- value = (value * 31) ^ hash(self.preferredBatchQueue)
- value = (value * 31) ^ hash(self.scratchLocation)
- value = (value * 31) ^ hash(self.allocationProjectNumber)
- value = (value * 31) ^ hash(self.resourceSpecificCredentialStoreToken)
- value = (value * 31) ^ hash(self.usageReportingGatewayId)
- value = (value * 31) ^ hash(self.qualityOfService)
- value = (value * 31) ^ hash(self.reservation)
- value = (value * 31) ^ hash(self.reservationStartTime)
- value = (value * 31) ^ hash(self.reservationEndTime)
- 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 StoragePreference:
- """
- Attributes:
- - storageResourceId
- - loginUserName
- - fileSystemRootLocation
- - resourceSpecificCredentialStoreToken
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'storageResourceId', None, None, ), # 1
- (2, TType.STRING, 'loginUserName', None, None, ), # 2
- (3, TType.STRING, 'fileSystemRootLocation', None, None, ), # 3
- (4, TType.STRING, 'resourceSpecificCredentialStoreToken', None, None, ), # 4
- )
-
- def __init__(self, storageResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,):
- self.storageResourceId = storageResourceId
- self.loginUserName = loginUserName
- self.fileSystemRootLocation = fileSystemRootLocation
- self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken
-
- 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.storageResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.loginUserName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.fileSystemRootLocation = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.resourceSpecificCredentialStoreToken = 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('StoragePreference')
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 1)
- oprot.writeString(self.storageResourceId)
- oprot.writeFieldEnd()
- if self.loginUserName is not None:
- oprot.writeFieldBegin('loginUserName', TType.STRING, 2)
- oprot.writeString(self.loginUserName)
- oprot.writeFieldEnd()
- if self.fileSystemRootLocation is not None:
- oprot.writeFieldBegin('fileSystemRootLocation', TType.STRING, 3)
- oprot.writeString(self.fileSystemRootLocation)
- oprot.writeFieldEnd()
- if self.resourceSpecificCredentialStoreToken is not None:
- oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 4)
- oprot.writeString(self.resourceSpecificCredentialStoreToken)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.storageResourceId is None:
- raise TProtocol.TProtocolException(message='Required field storageResourceId is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.storageResourceId)
- value = (value * 31) ^ hash(self.loginUserName)
- value = (value * 31) ^ hash(self.fileSystemRootLocation)
- value = (value * 31) ^ hash(self.resourceSpecificCredentialStoreToken)
- 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 GatewayResourceProfile:
- """
- Gateway Resource Profile
-
- gatewayID:
- Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
-
- credentialStoreToken:
- Gateway's defualt credential store token.
-
- computeResourcePreferences:
- List of resource preferences for each of the registered compute resources.
-
- identityServerTenant:
-
- identityServerPwdCredToken:
-
-
- Attributes:
- - gatewayID
- - credentialStoreToken
- - computeResourcePreferences
- - storagePreferences
- - identityServerTenant
- - identityServerPwdCredToken
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'gatewayID', None, None, ), # 1
- (2, TType.STRING, 'credentialStoreToken', None, None, ), # 2
- (3, TType.LIST, 'computeResourcePreferences', (TType.STRUCT,(ComputeResourcePreference, ComputeResourcePreference.thrift_spec)), None, ), # 3
- (4, TType.LIST, 'storagePreferences', (TType.STRUCT,(StoragePreference, StoragePreference.thrift_spec)), None, ), # 4
- (5, TType.STRING, 'identityServerTenant', None, None, ), # 5
- (6, TType.STRING, 'identityServerPwdCredToken', None, None, ), # 6
- )
-
- def __init__(self, gatewayID=None, credentialStoreToken=None, computeResourcePreferences=None, storagePreferences=None, identityServerTenant=None, identityServerPwdCredToken=None,):
- self.gatewayID = gatewayID
- self.credentialStoreToken = credentialStoreToken
- self.computeResourcePreferences = computeResourcePreferences
- self.storagePreferences = storagePreferences
- self.identityServerTenant = identityServerTenant
- self.identityServerPwdCredToken = identityServerPwdCredToken
-
- 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.gatewayID = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.credentialStoreToken = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.computeResourcePreferences = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = ComputeResourcePreference()
- _elem5.read(iprot)
- self.computeResourcePreferences.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.storagePreferences = []
- (_etype9, _size6) = iprot.readListBegin()
- for _i10 in xrange(_size6):
- _elem11 = StoragePreference()
- _elem11.read(iprot)
- self.storagePreferences.append(_elem11)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.identityServerTenant = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.identityServerPwdCredToken = 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('GatewayResourceProfile')
- if self.gatewayID is not None:
- oprot.writeFieldBegin('gatewayID', TType.STRING, 1)
- oprot.writeString(self.gatewayID)
- oprot.writeFieldEnd()
- if self.credentialStoreToken is not None:
- oprot.writeFieldBegin('credentialStoreToken', TType.STRING, 2)
- oprot.writeString(self.credentialStoreToken)
- oprot.writeFieldEnd()
- if self.computeResourcePreferences is not None:
- oprot.writeFieldBegin('computeResourcePreferences', TType.LIST, 3)
- oprot.writeListBegin(TType.STRUCT, len(self.computeResourcePreferences))
- for iter12 in self.computeResourcePreferences:
- iter12.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.storagePreferences is not None:
- oprot.writeFieldBegin('storagePreferences', TType.LIST, 4)
- oprot.writeListBegin(TType.STRUCT, len(self.storagePreferences))
- for iter13 in self.storagePreferences:
- iter13.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.identityServerTenant is not None:
- oprot.writeFieldBegin('identityServerTenant', TType.STRING, 5)
- oprot.writeString(self.identityServerTenant)
- oprot.writeFieldEnd()
- if self.identityServerPwdCredToken is not None:
- oprot.writeFieldBegin('identityServerPwdCredToken', TType.STRING, 6)
- oprot.writeString(self.identityServerPwdCredToken)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.gatewayID is None:
- raise TProtocol.TProtocolException(message='Required field gatewayID is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.gatewayID)
- value = (value * 31) ^ hash(self.credentialStoreToken)
- value = (value * 31) ^ hash(self.computeResourcePreferences)
- value = (value * 31) ^ hash(self.storagePreferences)
- value = (value * 31) ^ hash(self.identityServerTenant)
- value = (value * 31) ^ hash(self.identityServerPwdCredToken)
- 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 ComputeResourcePreference(object):
+ """
+ Gateway specific preferences for a Computer Resource
+
+ computeResourceId:
+ Corelate the preference to a compute resource.
+
+ overridebyAiravata:
+ If turned true, Airavata will override the preferences of better alternatives exist.
+
+ loginUserName:
+ If turned true, Airavata will override the preferences of better alternatives exist.
+
+ preferredJobSubmissionProtocol:
+ For resources with multiple job submission protocols, the gateway can pick a preferred option.
+
+ preferredDataMovementProtocol:
+ For resources with multiple data movement protocols, the gateway can pick a preferred option.
+
+ preferredBatchQueue:
+ Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics.
+
+ scratchLocation:
+ Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution.
+
+ allocationProjectNumber:
+ Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an
+ allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the
+ account to be used has to be added to the allocation.
+
+ resourceSpecificCredentialStoreToken:
+ Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's
+ default credential store.
+
+
+ Attributes:
+ - computeResourceId
+ - overridebyAiravata
+ - loginUserName
+ - preferredJobSubmissionProtocol
+ - preferredDataMovementProtocol
+ - preferredBatchQueue
+ - scratchLocation
+ - allocationProjectNumber
+ - resourceSpecificCredentialStoreToken
+ - usageReportingGatewayId
+ - qualityOfService
+ - reservation
+ - reservationStartTime
+ - reservationEndTime
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'computeResourceId', 'UTF8', None, ), # 1
+ (2, TType.BOOL, 'overridebyAiravata', None, True, ), # 2
+ (3, TType.STRING, 'loginUserName', 'UTF8', None, ), # 3
+ (4, TType.I32, 'preferredJobSubmissionProtocol', None, None, ), # 4
+ (5, TType.I32, 'preferredDataMovementProtocol', None, None, ), # 5
+ (6, TType.STRING, 'preferredBatchQueue', 'UTF8', None, ), # 6
+ (7, TType.STRING, 'scratchLocation', 'UTF8', None, ), # 7
+ (8, TType.STRING, 'allocationProjectNumber', 'UTF8', None, ), # 8
+ (9, TType.STRING, 'resourceSpecificCredentialStoreToken', 'UTF8', None, ), # 9
+ (10, TType.STRING, 'usageReportingGatewayId', 'UTF8', None, ), # 10
+ (11, TType.STRING, 'qualityOfService', 'UTF8', None, ), # 11
+ (12, TType.STRING, 'reservation', 'UTF8', None, ), # 12
+ (13, TType.I64, 'reservationStartTime', None, None, ), # 13
+ (14, TType.I64, 'reservationEndTime', None, None, ), # 14
+ )
+
+ def __init__(self, computeResourceId=None, overridebyAiravata=thrift_spec[2][4], loginUserName=None, preferredJobSubmissionProtocol=None, preferredDataMovementProtocol=None, preferredBatchQueue=None, scratchLocation=None, allocationProjectNumber=None, resourceSpecificCredentialStoreToken=None, usageReportingGatewayId=None, qualityOfService=None, reservation=None, reservationStartTime=None, reservationEndTime=None,):
+ self.computeResourceId = computeResourceId
+ self.overridebyAiravata = overridebyAiravata
+ self.loginUserName = loginUserName
+ self.preferredJobSubmissionProtocol = preferredJobSubmissionProtocol
+ self.preferredDataMovementProtocol = preferredDataMovementProtocol
+ self.preferredBatchQueue = preferredBatchQueue
+ self.scratchLocation = scratchLocation
+ self.allocationProjectNumber = allocationProjectNumber
+ self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken
+ self.usageReportingGatewayId = usageReportingGatewayId
+ self.qualityOfService = qualityOfService
+ self.reservation = reservation
+ self.reservationStartTime = reservationStartTime
+ self.reservationEndTime = reservationEndTime
+
+ 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.computeResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.BOOL:
+ self.overridebyAiravata = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.loginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.preferredJobSubmissionProtocol = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.preferredDataMovementProtocol = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.preferredBatchQueue = 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.scratchLocation = 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.allocationProjectNumber = 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.resourceSpecificCredentialStoreToken = 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.usageReportingGatewayId = 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.qualityOfService = 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.reservation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 13:
+ if ftype == TType.I64:
+ self.reservationStartTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 14:
+ if ftype == TType.I64:
+ self.reservationEndTime = iprot.readI64()
+ 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('ComputeResourcePreference')
+ if self.computeResourceId is not None:
+ oprot.writeFieldBegin('computeResourceId', TType.STRING, 1)
+ oprot.writeString(self.computeResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.computeResourceId)
+ oprot.writeFieldEnd()
+ if self.overridebyAiravata is not None:
+ oprot.writeFieldBegin('overridebyAiravata', TType.BOOL, 2)
+ oprot.writeBool(self.overridebyAiravata)
+ oprot.writeFieldEnd()
+ if self.loginUserName is not None:
+ oprot.writeFieldBegin('loginUserName', TType.STRING, 3)
+ oprot.writeString(self.loginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.loginUserName)
+ oprot.writeFieldEnd()
+ if self.preferredJobSubmissionProtocol is not None:
+ oprot.writeFieldBegin('preferredJobSubmissionProtocol', TType.I32, 4)
+ oprot.writeI32(self.preferredJobSubmissionProtocol)
+ oprot.writeFieldEnd()
+ if self.preferredDataMovementProtocol is not None:
+ oprot.writeFieldBegin('preferredDataMovementProtocol', TType.I32, 5)
+ oprot.writeI32(self.preferredDataMovementProtocol)
+ oprot.writeFieldEnd()
+ if self.preferredBatchQueue is not None:
+ oprot.writeFieldBegin('preferredBatchQueue', TType.STRING, 6)
+ oprot.writeString(self.preferredBatchQueue.encode('utf-8') if sys.version_info[0] == 2 else self.preferredBatchQueue)
+ oprot.writeFieldEnd()
+ if self.scratchLocation is not None:
+ oprot.writeFieldBegin('scratchLocation', TType.STRING, 7)
+ oprot.writeString(self.scratchLocation.encode('utf-8') if sys.version_info[0] == 2 else self.scratchLocation)
+ oprot.writeFieldEnd()
+ if self.allocationProjectNumber is not None:
+ oprot.writeFieldBegin('allocationProjectNumber', TType.STRING, 8)
+ oprot.writeString(self.allocationProjectNumber.encode('utf-8') if sys.version_info[0] == 2 else self.allocationProjectNumber)
+ oprot.writeFieldEnd()
+ if self.resourceSpecificCredentialStoreToken is not None:
+ oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 9)
+ oprot.writeString(self.resourceSpecificCredentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.resourceSpecificCredentialStoreToken)
+ oprot.writeFieldEnd()
+ if self.usageReportingGatewayId is not None:
+ oprot.writeFieldBegin('usageReportingGatewayId', TType.STRING, 10)
+ oprot.writeString(self.usageReportingGatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.usageReportingGatewayId)
+ oprot.writeFieldEnd()
+ if self.qualityOfService is not None:
+ oprot.writeFieldBegin('qualityOfService', TType.STRING, 11)
+ oprot.writeString(self.qualityOfService.encode('utf-8') if sys.version_info[0] == 2 else self.qualityOfService)
+ oprot.writeFieldEnd()
+ if self.reservation is not None:
+ oprot.writeFieldBegin('reservation', TType.STRING, 12)
+ oprot.writeString(self.reservation.encode('utf-8') if sys.version_info[0] == 2 else self.reservation)
+ oprot.writeFieldEnd()
+ if self.reservationStartTime is not None:
+ oprot.writeFieldBegin('reservationStartTime', TType.I64, 13)
+ oprot.writeI64(self.reservationStartTime)
+ oprot.writeFieldEnd()
+ if self.reservationEndTime is not None:
+ oprot.writeFieldBegin('reservationEndTime', TType.I64, 14)
+ oprot.writeI64(self.reservationEndTime)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.computeResourceId is None:
+ raise TProtocolException(message='Required field computeResourceId is unset!')
+ if self.overridebyAiravata is None:
+ raise TProtocolException(message='Required field overridebyAiravata 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 __ne__(self, other):
+ return not (self == other)
+
+
+class StoragePreference(object):
+ """
+ Attributes:
+ - storageResourceId
+ - loginUserName
+ - fileSystemRootLocation
+ - resourceSpecificCredentialStoreToken
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 1
+ (2, TType.STRING, 'loginUserName', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'fileSystemRootLocation', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'resourceSpecificCredentialStoreToken', 'UTF8', None, ), # 4
+ )
+
+ def __init__(self, storageResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,):
+ self.storageResourceId = storageResourceId
+ self.loginUserName = loginUserName
+ self.fileSystemRootLocation = fileSystemRootLocation
+ self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken
+
+ 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.storageResourceId = 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.loginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.fileSystemRootLocation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.resourceSpecificCredentialStoreToken = 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('StoragePreference')
+ if self.storageResourceId is not None:
+ oprot.writeFieldBegin('storageResourceId', TType.STRING, 1)
+ oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
+ oprot.writeFieldEnd()
+ if self.loginUserName is not None:
+ oprot.writeFieldBegin('loginUserName', TType.STRING, 2)
+ oprot.writeString(self.loginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.loginUserName)
+ oprot.writeFieldEnd()
+ if self.fileSystemRootLocation is not None:
+ oprot.writeFieldBegin('fileSystemRootLocation', TType.STRING, 3)
+ oprot.writeString(self.fileSystemRootLocation.encode('utf-8') if sys.version_info[0] == 2 else self.fileSystemRootLocation)
+ oprot.writeFieldEnd()
+ if self.resourceSpecificCredentialStoreToken is not None:
+ oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 4)
+ oprot.writeString(self.resourceSpecificCredentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.resourceSpecificCredentialStoreToken)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.storageResourceId is None:
+ raise TProtocolException(message='Required field storageResourceId 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 __ne__(self, other):
+ return not (self == other)
+
+
+class GatewayResourceProfile(object):
+ """
+ Gateway Resource Profile
+
+ gatewayID:
+ Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+
+ credentialStoreToken:
+ Gateway's defualt credential store token.
+
+ computeResourcePreferences:
+ List of resource preferences for each of the registered compute resources.
+
+ identityServerTenant:
+
+ identityServerPwdCredToken:
+
+
+ Attributes:
+ - gatewayID
+ - credentialStoreToken
+ - computeResourcePreferences
+ - storagePreferences
+ - identityServerTenant
+ - identityServerPwdCredToken
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'gatewayID', 'UTF8', None, ), # 1
+ (2, TType.STRING, 'credentialStoreToken', 'UTF8', None, ), # 2
+ (3, TType.LIST, 'computeResourcePreferences', (TType.STRUCT, (ComputeResourcePreference, ComputeResourcePreference.thrift_spec), False), None, ), # 3
+ (4, TType.LIST, 'storagePreferences', (TType.STRUCT, (StoragePreference, StoragePreference.thrift_spec), False), None, ), # 4
+ (5, TType.STRING, 'identityServerTenant', 'UTF8', None, ), # 5
+ (6, TType.STRING, 'identityServerPwdCredToken', 'UTF8', None, ), # 6
+ )
+
+ def __init__(self, gatewayID=None, credentialStoreToken=None, computeResourcePreferences=None, storagePreferences=None, identityServerTenant=None, identityServerPwdCredToken=None,):
+ self.gatewayID = gatewayID
+ self.credentialStoreToken = credentialStoreToken
+ self.computeResourcePreferences = computeResourcePreferences
+ self.storagePreferences = storagePreferences
+ self.identityServerTenant = identityServerTenant
+ self.identityServerPwdCredToken = identityServerPwdCredToken
+
+ 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.gatewayID = 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.credentialStoreToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.LIST:
+ self.computeResourcePreferences = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in range(_size0):
+ _elem5 = ComputeResourcePreference()
+ _elem5.read(iprot)
+ self.computeResourcePreferences.append(_elem5)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.LIST:
+ self.storagePreferences = []
+ (_etype9, _size6) = iprot.readListBegin()
+ for _i10 in range(_size6):
+ _elem11 = StoragePreference()
+ _elem11.read(iprot)
+ self.storagePreferences.append(_elem11)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.identityServerTenant = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.identityServerPwdCredToken = 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('GatewayResourceProfile')
+ if self.gatewayID is not None:
+ oprot.writeFieldBegin('gatewayID', TType.STRING, 1)
+ oprot.writeString(self.gatewayID.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayID)
+ oprot.writeFieldEnd()
+ if self.credentialStoreToken is not None:
+ oprot.writeFieldBegin('credentialStoreToken', TType.STRING, 2)
+ oprot.writeString(self.credentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.credentialStoreToken)
+ oprot.writeFieldEnd()
+ if self.computeResourcePreferences is not None:
+ oprot.writeFieldBegin('computeResourcePreferences', TType.LIST, 3)
+ oprot.writeListBegin(TType.STRUCT, len(self.computeResourcePreferences))
+ for iter12 in self.computeResourcePreferences:
+ iter12.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.storagePreferences is not None:
+ oprot.writeFieldBegin('storagePreferences', TType.LIST, 4)
+ oprot.writeListBegin(TType.STRUCT, len(self.storagePreferences))
+ for iter13 in self.storagePreferences:
+ iter13.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.identityServerTenant is not None:
+ oprot.writeFieldBegin('identityServerTenant', TType.STRING, 5)
+ oprot.writeString(self.identityServerTenant.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerTenant)
+ oprot.writeFieldEnd()
+ if self.identityServerPwdCredToken is not None:
+ oprot.writeFieldBegin('identityServerPwdCredToken', TType.STRING, 6)
+ oprot.writeString(self.identityServerPwdCredToken.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerPwdCredToken)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.gatewayID is None:
+ raise TProtocolException(message='Required field gatewayID 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 __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/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/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/ttypes.py
index 485d97e..4acb602 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/parallelism/ttypes.py
@@ -1,60 +1,56 @@
#
-# 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 ApplicationParallelismType:
- """
- Enumeration of application parallelism supported by Airavata
-
- SERIAL:
- Single processor applications without any parallelization.
-
- MPI:
- Messaging Passing Interface.
-
- OPENMP:
- Shared Memory Implementtaion.
-
- OPENMP_MPI:
- Hybrid Applications.
-
- """
- SERIAL = 0
- MPI = 1
- OPENMP = 2
- OPENMP_MPI = 3
- CCM = 4
- CRAY_MPI = 5
-
- _VALUES_TO_NAMES = {
- 0: "SERIAL",
- 1: "MPI",
- 2: "OPENMP",
- 3: "OPENMP_MPI",
- 4: "CCM",
- 5: "CRAY_MPI",
- }
-
- _NAMES_TO_VALUES = {
- "SERIAL": 0,
- "MPI": 1,
- "OPENMP": 2,
- "OPENMP_MPI": 3,
- "CCM": 4,
- "CRAY_MPI": 5,
- }
+
+class ApplicationParallelismType(object):
+ """
+ Enumeration of application parallelism supported by Airavata
+
+ SERIAL:
+ Single processor applications without any parallelization.
+
+ MPI:
+ Messaging Passing Interface.
+
+ OPENMP:
+ Shared Memory Implementtaion.
+
+ OPENMP_MPI:
+ Hybrid Applications.
+
+ """
+ SERIAL = 0
+ MPI = 1
+ OPENMP = 2
+ OPENMP_MPI = 3
+ CCM = 4
+ CRAY_MPI = 5
+
+ _VALUES_TO_NAMES = {
+ 0: "SERIAL",
+ 1: "MPI",
+ 2: "OPENMP",
+ 3: "OPENMP_MPI",
+ 4: "CCM",
+ 5: "CRAY_MPI",
+ }
+
+ _NAMES_TO_VALUES = {
+ "SERIAL": 0,
+ "MPI": 1,
+ "OPENMP": 2,
+ "OPENMP_MPI": 3,
+ "CCM": 4,
+ "CRAY_MPI": 5,
+ }
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/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/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/ttypes.py
index 32a9325..a33b14a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/storageresource/ttypes.py
@@ -1,167 +1,152 @@
#
-# 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.data.movement.ttypes
-
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-
-class StorageResourceDescription:
- """
- Storage Resource Description
-
- storageResourceId: Airavata Internal Unique Identifier to distinguish Compute Resource.
-
- hostName:
- Fully Qualified Host Name.
-
- storageResourceDescription:
- A user friendly description of the resource.
-
-
- DataMovementProtocol:
- Option to specify a prefered data movement mechanism of the available options.
-
-
-
- Attributes:
- - storageResourceId
- - hostName
- - storageResourceDescription
- - enabled
- - dataMovementInterfaces
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'storageResourceId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.STRING, 'hostName', None, None, ), # 2
- (3, TType.STRING, 'storageResourceDescription', None, None, ), # 3
- (4, TType.BOOL, 'enabled', None, None, ), # 4
- (5, TType.LIST, 'dataMovementInterfaces', (TType.STRUCT,(apache.airavata.model.data.movement.ttypes.DataMovementInterface, apache.airavata.model.data.movement.ttypes.DataMovementInterface.thrift_spec)), None, ), # 5
- )
-
- def __init__(self, storageResourceId=thrift_spec[1][4], hostName=None, storageResourceDescription=None, enabled=None, dataMovementInterfaces=None,):
- self.storageResourceId = storageResourceId
- self.hostName = hostName
- self.storageResourceDescription = storageResourceDescription
- self.enabled = enabled
- self.dataMovementInterfaces = dataMovementInterfaces
-
- 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.storageResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.hostName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.storageResourceDescription = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.BOOL:
- self.enabled = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.LIST:
- self.dataMovementInterfaces = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = apache.airavata.model.data.movement.ttypes.DataMovementInterface()
- _elem5.read(iprot)
- self.dataMovementInterfaces.append(_elem5)
- iprot.readListEnd()
- 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('StorageResourceDescription')
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 1)
- oprot.writeString(self.storageResourceId)
- oprot.writeFieldEnd()
- if self.hostName is not None:
- oprot.writeFieldBegin('hostName', TType.STRING, 2)
- oprot.writeString(self.hostName)
- oprot.writeFieldEnd()
- if self.storageResourceDescription is not None:
- oprot.writeFieldBegin('storageResourceDescription', TType.STRING, 3)
- oprot.writeString(self.storageResourceDescription)
- oprot.writeFieldEnd()
- if self.enabled is not None:
- oprot.writeFieldBegin('enabled', TType.BOOL, 4)
- oprot.writeBool(self.enabled)
- oprot.writeFieldEnd()
- if self.dataMovementInterfaces is not None:
- oprot.writeFieldBegin('dataMovementInterfaces', TType.LIST, 5)
- oprot.writeListBegin(TType.STRUCT, len(self.dataMovementInterfaces))
- for iter6 in self.dataMovementInterfaces:
- iter6.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.storageResourceId is None:
- raise TProtocol.TProtocolException(message='Required field storageResourceId is unset!')
- if self.hostName is None:
- raise TProtocol.TProtocolException(message='Required field hostName is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.storageResourceId)
- value = (value * 31) ^ hash(self.hostName)
- value = (value * 31) ^ hash(self.storageResourceDescription)
- value = (value * 31) ^ hash(self.enabled)
- value = (value * 31) ^ hash(self.dataMovementInterfaces)
- 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 StorageResourceDescription(object):
+ """
+ Storage Resource Description
+
+ storageResourceId: Airavata Internal Unique Identifier to distinguish Compute Resource.
+
+ hostName:
+ Fully Qualified Host Name.
+
+ storageResourceDescription:
+ A user friendly description of the resource.
+
+
+ DataMovementProtocol:
+ Option to specify a prefered data movement mechanism of the available options.
+
+
+
+ Attributes:
+ - storageResourceId
+ - hostName
+ - storageResourceDescription
+ - enabled
+ - dataMovementInterfaces
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'storageResourceId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
+ (2, TType.STRING, 'hostName', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'storageResourceDescription', 'UTF8', None, ), # 3
+ (4, TType.BOOL, 'enabled', None, None, ), # 4
+ (5, TType.LIST, 'dataMovementInterfaces', (TType.STRUCT, (apache.airavata.model.data.movement.ttypes.DataMovementInterface, apache.airavata.model.data.movement.ttypes.DataMovementInterface.thrift_spec), False), None, ), # 5
+ )
+
+ def __init__(self, storageResourceId=thrift_spec[1][4], hostName=None, storageResourceDescription=None, enabled=None, dataMovementInterfaces=None,):
+ self.storageResourceId = storageResourceId
+ self.hostName = hostName
+ self.storageResourceDescription = storageResourceDescription
+ self.enabled = enabled
+ self.dataMovementInterfaces = dataMovementInterfaces
+
+ 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.storageResourceId = 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.hostName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.storageResourceDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.BOOL:
+ self.enabled = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.LIST:
+ self.dataMovementInterfaces = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in range(_size0):
+ _elem5 = apache.airavata.model.data.movement.ttypes.DataMovementInterface()
+ _elem5.read(iprot)
+ self.dataMovementInterfaces.append(_elem5)
+ iprot.readListEnd()
+ 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('StorageResourceDescription')
+ if self.storageResourceId is not None:
+ oprot.writeFieldBegin('storageResourceId', TType.STRING, 1)
+ oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
+ oprot.writeFieldEnd()
+ if self.hostName is not None:
+ oprot.writeFieldBegin('hostName', TType.STRING, 2)
+ oprot.writeString(self.hostName.encode('utf-8') if sys.version_info[0] == 2 else self.hostName)
+ oprot.writeFieldEnd()
+ if self.storageResourceDescription is not None:
+ oprot.writeFieldBegin('storageResourceDescription', TType.STRING, 3)
+ oprot.writeString(self.storageResourceDescription.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceDescription)
+ oprot.writeFieldEnd()
+ if self.enabled is not None:
+ oprot.writeFieldBegin('enabled', TType.BOOL, 4)
+ oprot.writeBool(self.enabled)
+ oprot.writeFieldEnd()
+ if self.dataMovementInterfaces is not None:
+ oprot.writeFieldBegin('dataMovementInterfaces', TType.LIST, 5)
+ oprot.writeListBegin(TType.STRUCT, len(self.dataMovementInterfaces))
+ for iter6 in self.dataMovementInterfaces:
+ iter6.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.storageResourceId is None:
+ raise TProtocolException(message='Required field storageResourceId is unset!')
+ if self.hostName is None:
+ raise TProtocolException(message='Required field hostName 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 __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/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 *