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/09/21 16:59:45 UTC
[15/54] [abbrv] [partial] airavata-django-portal git commit: Moving
admin_view JS into django app and moving django project back
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py b/django_portal/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
deleted file mode 100644
index 7e7d4dc..0000000
--- a/django_portal/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py
+++ /dev/null
@@ -1,522 +0,0 @@
-#
-# 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, 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
-
-
-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-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/parallelism/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/parallelism/__init__.py b/django_portal/apache/airavata/model/appcatalog/parallelism/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/appcatalog/parallelism/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/parallelism/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/parallelism/constants.py b/django_portal/apache/airavata/model/appcatalog/parallelism/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/appcatalog/parallelism/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/parallelism/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/parallelism/ttypes.py b/django_portal/apache/airavata/model/appcatalog/parallelism/ttypes.py
deleted file mode 100644
index 4acb602..0000000
--- a/django_portal/apache/airavata/model/appcatalog/parallelism/ttypes.py
+++ /dev/null
@@ -1,56 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-
-from thrift.transport import TTransport
-
-
-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-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/storageresource/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/storageresource/__init__.py b/django_portal/apache/airavata/model/appcatalog/storageresource/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/appcatalog/storageresource/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/storageresource/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/storageresource/constants.py b/django_portal/apache/airavata/model/appcatalog/storageresource/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/appcatalog/storageresource/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/storageresource/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/storageresource/ttypes.py b/django_portal/apache/airavata/model/appcatalog/storageresource/ttypes.py
deleted file mode 100644
index a33b14a..0000000
--- a/django_portal/apache/airavata/model/appcatalog/storageresource/ttypes.py
+++ /dev/null
@@ -1,152 +0,0 @@
-#
-# 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, 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
-
-
-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-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/__init__.py b/django_portal/apache/airavata/model/appcatalog/userresourceprofile/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/constants.py b/django_portal/apache/airavata/model/appcatalog/userresourceprofile/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py b/django_portal/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py
deleted file mode 100644
index 1ce8736..0000000
--- a/django_portal/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py
+++ /dev/null
@@ -1,498 +0,0 @@
-#
-# 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, 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
-import apache.airavata.model.user.ttypes
-
-from thrift.transport import TTransport
-
-
-class UserComputeResourcePreference(object):
- """
- User specific preferences for a Computer Resource
-
- computeResourceId:
- Corelate the preference to a compute resource.
-
-
- loginUserName:
- If turned true, Airavata will override the preferences of better alternatives exist.
-
-
- 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
- - loginUserName
- - preferredBatchQueue
- - scratchLocation
- - allocationProjectNumber
- - resourceSpecificCredentialStoreToken
- - qualityOfService
- - reservation
- - reservationStartTime
- - reservationEndTime
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'computeResourceId', 'UTF8', None, ), # 1
- (2, TType.STRING, 'loginUserName', 'UTF8', None, ), # 2
- (3, TType.STRING, 'preferredBatchQueue', 'UTF8', None, ), # 3
- (4, TType.STRING, 'scratchLocation', 'UTF8', None, ), # 4
- (5, TType.STRING, 'allocationProjectNumber', 'UTF8', None, ), # 5
- (6, TType.STRING, 'resourceSpecificCredentialStoreToken', 'UTF8', None, ), # 6
- (7, TType.STRING, 'qualityOfService', 'UTF8', None, ), # 7
- (8, TType.STRING, 'reservation', 'UTF8', None, ), # 8
- (9, TType.I64, 'reservationStartTime', None, None, ), # 9
- (10, TType.I64, 'reservationEndTime', None, None, ), # 10
- )
-
- def __init__(self, computeResourceId=None, loginUserName=None, preferredBatchQueue=None, scratchLocation=None, allocationProjectNumber=None, resourceSpecificCredentialStoreToken=None, qualityOfService=None, reservation=None, reservationStartTime=None, reservationEndTime=None,):
- self.computeResourceId = computeResourceId
- self.loginUserName = loginUserName
- self.preferredBatchQueue = preferredBatchQueue
- self.scratchLocation = scratchLocation
- self.allocationProjectNumber = allocationProjectNumber
- self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken
- 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.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.preferredBatchQueue = 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.scratchLocation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- 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 == 6:
- 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 == 7:
- 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 == 8:
- 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 == 9:
- if ftype == TType.I64:
- self.reservationStartTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- 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('UserComputeResourcePreference')
- 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.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.preferredBatchQueue is not None:
- oprot.writeFieldBegin('preferredBatchQueue', TType.STRING, 3)
- 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, 4)
- 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, 5)
- 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, 6)
- oprot.writeString(self.resourceSpecificCredentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.resourceSpecificCredentialStoreToken)
- oprot.writeFieldEnd()
- if self.qualityOfService is not None:
- oprot.writeFieldBegin('qualityOfService', TType.STRING, 7)
- 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, 8)
- 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, 9)
- oprot.writeI64(self.reservationStartTime)
- oprot.writeFieldEnd()
- if self.reservationEndTime is not None:
- oprot.writeFieldBegin('reservationEndTime', TType.I64, 10)
- 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!')
- 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 UserStoragePreference(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('UserStoragePreference')
- 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 UserResourceProfile(object):
- """
- User Resource Profile
-
- userId:
- Unique identifier used to link user to corresponding user data model
-
- 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:
-
- isNull:
- Indicates that this instance is just a container for a null value.
-
-
- Attributes:
- - userId
- - gatewayID
- - credentialStoreToken
- - userComputeResourcePreferences
- - userStoragePreferences
- - identityServerTenant
- - identityServerPwdCredToken
- - isNull
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'userId', 'UTF8', None, ), # 1
- (2, TType.STRING, 'gatewayID', 'UTF8', None, ), # 2
- (3, TType.STRING, 'credentialStoreToken', 'UTF8', None, ), # 3
- (4, TType.LIST, 'userComputeResourcePreferences', (TType.STRUCT, (UserComputeResourcePreference, UserComputeResourcePreference.thrift_spec), False), None, ), # 4
- (5, TType.LIST, 'userStoragePreferences', (TType.STRUCT, (UserStoragePreference, UserStoragePreference.thrift_spec), False), None, ), # 5
- (6, TType.STRING, 'identityServerTenant', 'UTF8', None, ), # 6
- (7, TType.STRING, 'identityServerPwdCredToken', 'UTF8', None, ), # 7
- (8, TType.BOOL, 'isNull', None, False, ), # 8
- )
-
- def __init__(self, userId=None, gatewayID=None, credentialStoreToken=None, userComputeResourcePreferences=None, userStoragePreferences=None, identityServerTenant=None, identityServerPwdCredToken=None, isNull=thrift_spec[8][4],):
- self.userId = userId
- self.gatewayID = gatewayID
- self.credentialStoreToken = credentialStoreToken
- self.userComputeResourcePreferences = userComputeResourcePreferences
- self.userStoragePreferences = userStoragePreferences
- self.identityServerTenant = identityServerTenant
- self.identityServerPwdCredToken = identityServerPwdCredToken
- self.isNull = isNull
-
- 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.userId = 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.gatewayID = 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.credentialStoreToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.userComputeResourcePreferences = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in range(_size0):
- _elem5 = UserComputeResourcePreference()
- _elem5.read(iprot)
- self.userComputeResourcePreferences.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.LIST:
- self.userStoragePreferences = []
- (_etype9, _size6) = iprot.readListBegin()
- for _i10 in range(_size6):
- _elem11 = UserStoragePreference()
- _elem11.read(iprot)
- self.userStoragePreferences.append(_elem11)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- 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 == 7:
- if ftype == TType.STRING:
- self.identityServerPwdCredToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.BOOL:
- self.isNull = 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('UserResourceProfile')
- if self.userId is not None:
- oprot.writeFieldBegin('userId', TType.STRING, 1)
- oprot.writeString(self.userId.encode('utf-8') if sys.version_info[0] == 2 else self.userId)
- oprot.writeFieldEnd()
- if self.gatewayID is not None:
- oprot.writeFieldBegin('gatewayID', TType.STRING, 2)
- 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, 3)
- oprot.writeString(self.credentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.credentialStoreToken)
- oprot.writeFieldEnd()
- if self.userComputeResourcePreferences is not None:
- oprot.writeFieldBegin('userComputeResourcePreferences', TType.LIST, 4)
- oprot.writeListBegin(TType.STRUCT, len(self.userComputeResourcePreferences))
- for iter12 in self.userComputeResourcePreferences:
- iter12.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.userStoragePreferences is not None:
- oprot.writeFieldBegin('userStoragePreferences', TType.LIST, 5)
- oprot.writeListBegin(TType.STRUCT, len(self.userStoragePreferences))
- for iter13 in self.userStoragePreferences:
- iter13.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.identityServerTenant is not None:
- oprot.writeFieldBegin('identityServerTenant', TType.STRING, 6)
- 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, 7)
- oprot.writeString(self.identityServerPwdCredToken.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerPwdCredToken)
- oprot.writeFieldEnd()
- if self.isNull is not None:
- oprot.writeFieldBegin('isNull', TType.BOOL, 8)
- oprot.writeBool(self.isNull)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.userId is None:
- raise TProtocolException(message='Required field userId is unset!')
- 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-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/application/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/application/__init__.py b/django_portal/apache/airavata/model/application/__init__.py
deleted file mode 100644
index e69de29..0000000
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/application/io/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/application/io/__init__.py b/django_portal/apache/airavata/model/application/io/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/application/io/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/application/io/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/application/io/constants.py b/django_portal/apache/airavata/model/application/io/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/application/io/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/application/io/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/application/io/ttypes.py b/django_portal/apache/airavata/model/application/io/ttypes.py
deleted file mode 100644
index da1e363..0000000
--- a/django_portal/apache/airavata/model/application/io/ttypes.py
+++ /dev/null
@@ -1,486 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-import apache.airavata.model.appcatalog.computeresource.ttypes
-
-from thrift.transport import TTransport
-
-
-class DataType(object):
- """
- Data Types supported in Airavata. The primitive data types
-
- """
- STRING = 0
- INTEGER = 1
- FLOAT = 2
- URI = 3
- URI_COLLECTION = 4
- STDOUT = 5
- STDERR = 6
-
- _VALUES_TO_NAMES = {
- 0: "STRING",
- 1: "INTEGER",
- 2: "FLOAT",
- 3: "URI",
- 4: "URI_COLLECTION",
- 5: "STDOUT",
- 6: "STDERR",
- }
-
- _NAMES_TO_VALUES = {
- "STRING": 0,
- "INTEGER": 1,
- "FLOAT": 2,
- "URI": 3,
- "URI_COLLECTION": 4,
- "STDOUT": 5,
- "STDERR": 6,
- }
-
-
-class InputDataObjectType(object):
- """
- Application Inputs. The paramters describe how inputs are passed to the application.
-
- name:
- Name of the parameter.
-
- value:
- Value of the parameter. A default value could be set during registration.
-
- type:
- Data type of the parameter
-
- applicationArguement:
- The argument flag sent to the application. Such as -p pressure.
-
- standardInput:
- When this value is set, the parameter is sent as standard input rather than a parameter.
- Typically this is passed using redirection operator ">".
-
- userFriendlyDescription:
- Description to be displayed at the user interface.
-
- metaData:
- Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration.
-
-
- Attributes:
- - name
- - value
- - type
- - applicationArgument
- - standardInput
- - userFriendlyDescription
- - metaData
- - inputOrder
- - isRequired
- - requiredToAddedToCommandLine
- - dataStaged
- - storageResourceId
- - isReadOnly
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'name', 'UTF8', None, ), # 1
- (2, TType.STRING, 'value', 'UTF8', None, ), # 2
- (3, TType.I32, 'type', None, None, ), # 3
- (4, TType.STRING, 'applicationArgument', 'UTF8', None, ), # 4
- (5, TType.BOOL, 'standardInput', None, None, ), # 5
- (6, TType.STRING, 'userFriendlyDescription', 'UTF8', None, ), # 6
- (7, TType.STRING, 'metaData', 'UTF8', None, ), # 7
- (8, TType.I32, 'inputOrder', None, None, ), # 8
- (9, TType.BOOL, 'isRequired', None, None, ), # 9
- (10, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 10
- (11, TType.BOOL, 'dataStaged', None, None, ), # 11
- (12, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 12
- (13, TType.BOOL, 'isReadOnly', None, None, ), # 13
- )
-
- def __init__(self, name=None, value=None, type=None, applicationArgument=None, standardInput=None, userFriendlyDescription=None, metaData=None, inputOrder=None, isRequired=None, requiredToAddedToCommandLine=None, dataStaged=None, storageResourceId=None, isReadOnly=None,):
- self.name = name
- self.value = value
- self.type = type
- self.applicationArgument = applicationArgument
- self.standardInput = standardInput
- self.userFriendlyDescription = userFriendlyDescription
- self.metaData = metaData
- self.inputOrder = inputOrder
- self.isRequired = isRequired
- self.requiredToAddedToCommandLine = requiredToAddedToCommandLine
- self.dataStaged = dataStaged
- self.storageResourceId = storageResourceId
- self.isReadOnly = isReadOnly
-
- 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.name = 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.value = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.applicationArgument = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.standardInput = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.userFriendlyDescription = 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.metaData = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I32:
- self.inputOrder = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.BOOL:
- self.isRequired = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.BOOL:
- self.requiredToAddedToCommandLine = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.BOOL:
- self.dataStaged = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- 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 == 13:
- if ftype == TType.BOOL:
- self.isReadOnly = 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('InputDataObjectType')
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 1)
- oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name)
- oprot.writeFieldEnd()
- if self.value is not None:
- oprot.writeFieldBegin('value', TType.STRING, 2)
- oprot.writeString(self.value.encode('utf-8') if sys.version_info[0] == 2 else self.value)
- oprot.writeFieldEnd()
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 3)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.applicationArgument is not None:
- oprot.writeFieldBegin('applicationArgument', TType.STRING, 4)
- oprot.writeString(self.applicationArgument.encode('utf-8') if sys.version_info[0] == 2 else self.applicationArgument)
- oprot.writeFieldEnd()
- if self.standardInput is not None:
- oprot.writeFieldBegin('standardInput', TType.BOOL, 5)
- oprot.writeBool(self.standardInput)
- oprot.writeFieldEnd()
- if self.userFriendlyDescription is not None:
- oprot.writeFieldBegin('userFriendlyDescription', TType.STRING, 6)
- oprot.writeString(self.userFriendlyDescription.encode('utf-8') if sys.version_info[0] == 2 else self.userFriendlyDescription)
- oprot.writeFieldEnd()
- if self.metaData is not None:
- oprot.writeFieldBegin('metaData', TType.STRING, 7)
- oprot.writeString(self.metaData.encode('utf-8') if sys.version_info[0] == 2 else self.metaData)
- oprot.writeFieldEnd()
- if self.inputOrder is not None:
- oprot.writeFieldBegin('inputOrder', TType.I32, 8)
- oprot.writeI32(self.inputOrder)
- oprot.writeFieldEnd()
- if self.isRequired is not None:
- oprot.writeFieldBegin('isRequired', TType.BOOL, 9)
- oprot.writeBool(self.isRequired)
- oprot.writeFieldEnd()
- if self.requiredToAddedToCommandLine is not None:
- oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 10)
- oprot.writeBool(self.requiredToAddedToCommandLine)
- oprot.writeFieldEnd()
- if self.dataStaged is not None:
- oprot.writeFieldBegin('dataStaged', TType.BOOL, 11)
- oprot.writeBool(self.dataStaged)
- oprot.writeFieldEnd()
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 12)
- oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
- oprot.writeFieldEnd()
- if self.isReadOnly is not None:
- oprot.writeFieldBegin('isReadOnly', TType.BOOL, 13)
- oprot.writeBool(self.isReadOnly)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.name is None:
- raise TProtocolException(message='Required field name 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 OutputDataObjectType(object):
- """
- Application Outputs. The paramters describe how outputs generated by the application.
-
- name:
- Name of the parameter.
-
- value:
- Value of the parameter.
-
- type:
- Data type of the parameter
-
- applicationArguement:
- The argument flag sent to the application. Such as -p pressure.
-
- standardInput:
- When this value is set, the parameter is sent as standard input rather than a parameter.
- Typically this is passed using redirection operator ">".
-
- userFriendlyDescription:
- Description to be displayed at the user interface.
-
- metaData:
- Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration.
-
-
- Attributes:
- - name
- - value
- - type
- - applicationArgument
- - isRequired
- - requiredToAddedToCommandLine
- - dataMovement
- - location
- - searchQuery
- - outputStreaming
- - storageResourceId
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'name', 'UTF8', None, ), # 1
- (2, TType.STRING, 'value', 'UTF8', None, ), # 2
- (3, TType.I32, 'type', None, None, ), # 3
- (4, TType.STRING, 'applicationArgument', 'UTF8', None, ), # 4
- (5, TType.BOOL, 'isRequired', None, None, ), # 5
- (6, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 6
- (7, TType.BOOL, 'dataMovement', None, None, ), # 7
- (8, TType.STRING, 'location', 'UTF8', None, ), # 8
- (9, TType.STRING, 'searchQuery', 'UTF8', None, ), # 9
- (10, TType.BOOL, 'outputStreaming', None, None, ), # 10
- (11, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 11
- )
-
- def __init__(self, name=None, value=None, type=None, applicationArgument=None, isRequired=None, requiredToAddedToCommandLine=None, dataMovement=None, location=None, searchQuery=None, outputStreaming=None, storageResourceId=None,):
- self.name = name
- self.value = value
- self.type = type
- self.applicationArgument = applicationArgument
- self.isRequired = isRequired
- self.requiredToAddedToCommandLine = requiredToAddedToCommandLine
- self.dataMovement = dataMovement
- self.location = location
- self.searchQuery = searchQuery
- self.outputStreaming = outputStreaming
- self.storageResourceId = storageResourceId
-
- 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.name = 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.value = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.applicationArgument = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.isRequired = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.BOOL:
- self.requiredToAddedToCommandLine = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.BOOL:
- self.dataMovement = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.location = 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.searchQuery = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.BOOL:
- self.outputStreaming = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.storageResourceId = 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('OutputDataObjectType')
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 1)
- oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name)
- oprot.writeFieldEnd()
- if self.value is not None:
- oprot.writeFieldBegin('value', TType.STRING, 2)
- oprot.writeString(self.value.encode('utf-8') if sys.version_info[0] == 2 else self.value)
- oprot.writeFieldEnd()
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 3)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.applicationArgument is not None:
- oprot.writeFieldBegin('applicationArgument', TType.STRING, 4)
- oprot.writeString(self.applicationArgument.encode('utf-8') if sys.version_info[0] == 2 else self.applicationArgument)
- oprot.writeFieldEnd()
- if self.isRequired is not None:
- oprot.writeFieldBegin('isRequired', TType.BOOL, 5)
- oprot.writeBool(self.isRequired)
- oprot.writeFieldEnd()
- if self.requiredToAddedToCommandLine is not None:
- oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 6)
- oprot.writeBool(self.requiredToAddedToCommandLine)
- oprot.writeFieldEnd()
- if self.dataMovement is not None:
- oprot.writeFieldBegin('dataMovement', TType.BOOL, 7)
- oprot.writeBool(self.dataMovement)
- oprot.writeFieldEnd()
- if self.location is not None:
- oprot.writeFieldBegin('location', TType.STRING, 8)
- oprot.writeString(self.location.encode('utf-8') if sys.version_info[0] == 2 else self.location)
- oprot.writeFieldEnd()
- if self.searchQuery is not None:
- oprot.writeFieldBegin('searchQuery', TType.STRING, 9)
- oprot.writeString(self.searchQuery.encode('utf-8') if sys.version_info[0] == 2 else self.searchQuery)
- oprot.writeFieldEnd()
- if self.outputStreaming is not None:
- oprot.writeFieldBegin('outputStreaming', TType.BOOL, 10)
- oprot.writeBool(self.outputStreaming)
- oprot.writeFieldEnd()
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 11)
- oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.name is None:
- raise TProtocolException(message='Required field name 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-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/commons/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/commons/__init__.py b/django_portal/apache/airavata/model/commons/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/commons/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/commons/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/commons/constants.py b/django_portal/apache/airavata/model/commons/constants.py
deleted file mode 100644
index 2b09fa9..0000000
--- a/django_portal/apache/airavata/model/commons/constants.py
+++ /dev/null
@@ -1,13 +0,0 @@
-#
-# 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, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
-DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS"