http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/__init__.py new file mode 100644 index 0000000..e85fb34 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants', 'Airavata']
http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/constants.py new file mode 100644 index 0000000..05093fe --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 * + +AIRAVATA_API_VERSION = "0.15.0" http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/constants.py new file mode 100644 index 0000000..35216c6 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/constants.py @@ -0,0 +1,11 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 * + http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/ttypes.py new file mode 100644 index 0000000..24999f4 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/error/ttypes.py @@ -0,0 +1,881 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 +import apache.airavata.model.workspace.experiment.ttypes + + +from thrift.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + +class AiravataErrorType: + """ + A list of Airavata API Error Message Types + + UNKNOWN: No information available about the error + + PERMISSION_DENIED: Not permitted to perform action + + INTERNAL_ERROR: Unexpected problem with the service + + AUTHENTICATION_FAILURE: The client failed to authenticate. + + INVALID_AUTHORIZATION: Security Token and/or Username and/or password is incorrect + + AUTHORIZATION_EXPIRED: Authentication token expired + + UNKNOWN_GATEWAY_ID: The gateway is not registered with Airavata. + + UNSUPPORTED_OPERATION: Operation denied because it is currently unsupported. + """ + UNKNOWN = 0 + PERMISSION_DENIED = 1 + INTERNAL_ERROR = 2 + AUTHENTICATION_FAILURE = 3 + INVALID_AUTHORIZATION = 4 + AUTHORIZATION_EXPIRED = 5 + UNKNOWN_GATEWAY_ID = 6 + UNSUPPORTED_OPERATION = 7 + + _VALUES_TO_NAMES = { + 0: "UNKNOWN", + 1: "PERMISSION_DENIED", + 2: "INTERNAL_ERROR", + 3: "AUTHENTICATION_FAILURE", + 4: "INVALID_AUTHORIZATION", + 5: "AUTHORIZATION_EXPIRED", + 6: "UNKNOWN_GATEWAY_ID", + 7: "UNSUPPORTED_OPERATION", + } + + _NAMES_TO_VALUES = { + "UNKNOWN": 0, + "PERMISSION_DENIED": 1, + "INTERNAL_ERROR": 2, + "AUTHENTICATION_FAILURE": 3, + "INVALID_AUTHORIZATION": 4, + "AUTHORIZATION_EXPIRED": 5, + "UNKNOWN_GATEWAY_ID": 6, + "UNSUPPORTED_OPERATION": 7, + } + + +class ExperimentNotFoundException(TException): + """ + This exception is thrown when a client asks to perform an operation on an experiment that does not exist. + + identifier: A description of the experiment that was not found on the server. + + key: The value passed from the client in the identifier, which was not found. + + Attributes: + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'message', None, None, ), # 1 + ) + + def __init__(self, message=None,): + self.message = message + + 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.message = 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('ExperimentNotFoundException') + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 1) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.message is None: + raise TProtocol.TProtocolException(message='Required field message is unset!') + return + + + def __str__(self): + return repr(self) + + 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 ProjectNotFoundException(TException): + """ + 1: optional string identifier, + 2: optional string key + + + Attributes: + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'message', None, None, ), # 1 + ) + + def __init__(self, message=None,): + self.message = message + + 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.message = 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('ProjectNotFoundException') + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 1) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.message is None: + raise TProtocol.TProtocolException(message='Required field message is unset!') + return + + + def __str__(self): + return repr(self) + + 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 InvalidRequestException(TException): + """ + This exception is thrown for invalid requests that occur from any reasons like required input parameters are missing, + or a parameter is malformed. + + message: contains the associated error message. + + Attributes: + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'message', None, None, ), # 1 + ) + + def __init__(self, message=None,): + self.message = message + + 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.message = 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('InvalidRequestException') + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 1) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.message is None: + raise TProtocol.TProtocolException(message='Required field message is unset!') + return + + + def __str__(self): + return repr(self) + + 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 TimedOutException(TException): + """ + This exception is thrown when RPC timeout gets exceeded. + """ + + thrift_spec = ( + ) + + 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 + 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('TimedOutException') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __str__(self): + return repr(self) + + 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 AuthenticationException(TException): + """ + This exception is thrown for invalid authentication requests. + + message: contains the cause of the authorization failure. + + Attributes: + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'message', None, None, ), # 1 + ) + + def __init__(self, message=None,): + self.message = message + + 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.message = 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('AuthenticationException') + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 1) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.message is None: + raise TProtocol.TProtocolException(message='Required field message is unset!') + return + + + def __str__(self): + return repr(self) + + 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 AuthorizationException(TException): + """ + This exception is thrown for invalid authorization requests such user does not have acces to an aplication or resource. + + message: contains the authorization failure message + + Attributes: + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'message', None, None, ), # 1 + ) + + def __init__(self, message=None,): + self.message = message + + 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.message = 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('AuthorizationException') + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 1) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.message is None: + raise TProtocol.TProtocolException(message='Required field message is unset!') + return + + + def __str__(self): + return repr(self) + + 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 AiravataClientException(TException): + """ + This exception is thrown by Airavata Services when a call fails as a result of + a problem that a client may be able to resolve. For example, if the user + attempts to execute an application on a resource gateway does not have access to. + + This exception would not be used for internal system errors that do not + reflect user actions, but rather reflect a problem within the service that + the client cannot resolve. + + airavataErrorType: The message type indicating the error that occurred. + must be one of the values of AiravataErrorType. + + parameter: If the error applied to a particular input parameter, this will + indicate which parameter. + + Attributes: + - airavataErrorType + - parameter + """ + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'airavataErrorType', None, None, ), # 1 + (2, TType.STRING, 'parameter', None, None, ), # 2 + ) + + def __init__(self, airavataErrorType=None, parameter=None,): + self.airavataErrorType = airavataErrorType + self.parameter = parameter + + 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.I32: + self.airavataErrorType = iprot.readI32(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.parameter = 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('AiravataClientException') + if self.airavataErrorType is not None: + oprot.writeFieldBegin('airavataErrorType', TType.I32, 1) + oprot.writeI32(self.airavataErrorType) + oprot.writeFieldEnd() + if self.parameter is not None: + oprot.writeFieldBegin('parameter', TType.STRING, 2) + oprot.writeString(self.parameter) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.airavataErrorType is None: + raise TProtocol.TProtocolException(message='Required field airavataErrorType is unset!') + return + + + def __str__(self): + return repr(self) + + 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 ValidatorResult: + """ + Attributes: + - result + - errorDetails + """ + + thrift_spec = ( + None, # 0 + (1, TType.BOOL, 'result', None, None, ), # 1 + (2, TType.STRING, 'errorDetails', None, None, ), # 2 + ) + + def __init__(self, result=None, errorDetails=None,): + self.result = result + self.errorDetails = errorDetails + + 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.BOOL: + self.result = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.errorDetails = 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('ValidatorResult') + if self.result is not None: + oprot.writeFieldBegin('result', TType.BOOL, 1) + oprot.writeBool(self.result) + oprot.writeFieldEnd() + if self.errorDetails is not None: + oprot.writeFieldBegin('errorDetails', TType.STRING, 2) + oprot.writeString(self.errorDetails) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.result is None: + raise TProtocol.TProtocolException(message='Required field result is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ValidationResults: + """ + Attributes: + - validationState + - validationResultList + """ + + thrift_spec = ( + None, # 0 + (1, TType.BOOL, 'validationState', None, None, ), # 1 + (2, TType.LIST, 'validationResultList', (TType.STRUCT,(ValidatorResult, ValidatorResult.thrift_spec)), None, ), # 2 + ) + + def __init__(self, validationState=None, validationResultList=None,): + self.validationState = validationState + self.validationResultList = validationResultList + + 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.BOOL: + self.validationState = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.LIST: + self.validationResultList = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in xrange(_size0): + _elem5 = ValidatorResult() + _elem5.read(iprot) + self.validationResultList.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('ValidationResults') + if self.validationState is not None: + oprot.writeFieldBegin('validationState', TType.BOOL, 1) + oprot.writeBool(self.validationState) + oprot.writeFieldEnd() + if self.validationResultList is not None: + oprot.writeFieldBegin('validationResultList', TType.LIST, 2) + oprot.writeListBegin(TType.STRUCT, len(self.validationResultList)) + for iter6 in self.validationResultList: + iter6.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.validationState is None: + raise TProtocol.TProtocolException(message='Required field validationState is unset!') + if self.validationResultList is None: + raise TProtocol.TProtocolException(message='Required field validationResultList is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class LaunchValidationException(TException): + """ + Attributes: + - validationResult + - errorMessage + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'validationResult', (ValidationResults, ValidationResults.thrift_spec), None, ), # 1 + (2, TType.STRING, 'errorMessage', None, None, ), # 2 + ) + + def __init__(self, validationResult=None, errorMessage=None,): + self.validationResult = validationResult + self.errorMessage = errorMessage + + 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.STRUCT: + self.validationResult = ValidationResults() + self.validationResult.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.errorMessage = 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('LaunchValidationException') + if self.validationResult is not None: + oprot.writeFieldBegin('validationResult', TType.STRUCT, 1) + self.validationResult.write(oprot) + oprot.writeFieldEnd() + if self.errorMessage is not None: + oprot.writeFieldBegin('errorMessage', TType.STRING, 2) + oprot.writeString(self.errorMessage) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.validationResult is None: + raise TProtocol.TProtocolException(message='Required field validationResult is unset!') + return + + + def __str__(self): + return repr(self) + + 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 AiravataSystemException(TException): + """ + This exception is thrown by Airavata Services when a call fails as a result of + a problem in the service that could not be changed through client's action. + + airavataErrorType: The message type indicating the error that occurred. + must be one of the values of AiravataErrorType. + + message: This may contain additional information about the error + + + Attributes: + - airavataErrorType + - message + """ + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'airavataErrorType', None, None, ), # 1 + (2, TType.STRING, 'message', None, None, ), # 2 + ) + + def __init__(self, airavataErrorType=None, message=None,): + self.airavataErrorType = airavataErrorType + self.message = message + + 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.I32: + self.airavataErrorType = iprot.readI32(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.message = 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('AiravataSystemException') + if self.airavataErrorType is not None: + oprot.writeFieldBegin('airavataErrorType', TType.I32, 1) + oprot.writeI32(self.airavataErrorType) + oprot.writeFieldEnd() + if self.message is not None: + oprot.writeFieldBegin('message', TType.STRING, 2) + oprot.writeString(self.message) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.airavataErrorType is None: + raise TProtocol.TProtocolException(message='Required field airavataErrorType is unset!') + return + + + def __str__(self): + return repr(self) + + 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py new file mode 100644 index 0000000..09140d0 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py @@ -0,0 +1,28 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 +import apache.airavata.api.error.ttypes +import apache.airavata.model.ttypes +import apache.airavata.model.workspace.experiment.ttypes +import apache.airavata.model.workspace.ttypes +import apache.airavata.model.appcatalog.computeresource.ttypes +import apache.airavata.model.appcatalog.appdeployment.ttypes +import apache.airavata.model.appcatalog.appinterface.ttypes +import apache.airavata.model.appcatalog.gatewayprofile.ttypes +import apache.airavata.model.workflow.ttypes + + +from thrift.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/__init__.py new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/constants.py new file mode 100644 index 0000000..249ecf4 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 * + +DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS" http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/ttypes.py new file mode 100644 index 0000000..7383b6d --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appdeployment/ttypes.py @@ -0,0 +1,530 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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.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 + + _VALUES_TO_NAMES = { + 0: "SERIAL", + 1: "MPI", + 2: "OPENMP", + 3: "OPENMP_MPI", + } + + _NAMES_TO_VALUES = { + "SERIAL": 0, + "MPI": 1, + "OPENMP": 2, + "OPENMP_MPI": 3, + } + + +class SetEnvPaths: + """ + Key Value pairs to be used to set environments + + name: + Name of the environment variable such as PATH, LD_LIBRARY_PATH, NETCDF_HOME. + + value: + Value of the environment variable to set + + Attributes: + - name + - value + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.STRING, 'value', None, None, ), # 2 + ) + + def __init__(self, name=None, value=None,): + self.name = name + self.value = value + + 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.name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = 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('SetEnvPaths') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(self.value) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.name is None: + raise TProtocol.TProtocolException(message='Required field name is unset!') + if self.value is None: + raise TProtocol.TProtocolException(message='Required field value is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ApplicationModule: + """ + Application Module Information. A module has to be registered before registering a deployment. + + appModuleId: Airavata Internal Unique Job ID. This is set by the registry. + + appModuleName: + Name of the application module. + + appModuleVersion: + Version of the application. + + appModuleDescription: + Descriprion of the Module + + + Attributes: + - appModuleId + - appModuleName + - appModuleVersion + - appModuleDescription + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'appModuleId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'appModuleName', None, None, ), # 2 + (3, TType.STRING, 'appModuleVersion', None, None, ), # 3 + (4, TType.STRING, 'appModuleDescription', None, None, ), # 4 + ) + + def __init__(self, appModuleId=thrift_spec[1][4], appModuleName=None, appModuleVersion=None, appModuleDescription=None,): + self.appModuleId = appModuleId + self.appModuleName = appModuleName + self.appModuleVersion = appModuleVersion + self.appModuleDescription = appModuleDescription + + 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.appModuleId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appModuleName = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.appModuleVersion = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.appModuleDescription = 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('ApplicationModule') + if self.appModuleId is not None: + oprot.writeFieldBegin('appModuleId', TType.STRING, 1) + oprot.writeString(self.appModuleId) + oprot.writeFieldEnd() + if self.appModuleName is not None: + oprot.writeFieldBegin('appModuleName', TType.STRING, 2) + oprot.writeString(self.appModuleName) + oprot.writeFieldEnd() + if self.appModuleVersion is not None: + oprot.writeFieldBegin('appModuleVersion', TType.STRING, 3) + oprot.writeString(self.appModuleVersion) + oprot.writeFieldEnd() + if self.appModuleDescription is not None: + oprot.writeFieldBegin('appModuleDescription', TType.STRING, 4) + oprot.writeString(self.appModuleDescription) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.appModuleId is None: + raise TProtocol.TProtocolException(message='Required field appModuleId is unset!') + if self.appModuleName is None: + raise TProtocol.TProtocolException(message='Required field appModuleName is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ApplicationDeploymentDescription: + """ + Application Deployment Description + + appDeploymentId: Airavata Internal Unique Job ID. This is set by the registry. + + appModuleName: + Application Module Name. This has to be precise describing the binary. + + computeHostId: + This ID maps application deployment to a particular resource previously described within Airavata. + Example: Stampede is first registered and refered when registering WRF. + + moduleLoadCmd: + Command string to load modules. This will be placed in the job submisison + Ex: module load amber + + libPrependPaths: + prepend to a path variable the value + + libAppendPaths: + append to a path variable the value + + setEnvironment: + assigns to the environment variable "NAME" the value + + + Attributes: + - appDeploymentId + - appModuleId + - computeHostId + - executablePath + - parallelism + - appDeploymentDescription + - moduleLoadCmds + - libPrependPaths + - libAppendPaths + - setEnvironment + - preJobCommands + - postJobCommands + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'appDeploymentId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'appModuleId', None, None, ), # 2 + (3, TType.STRING, 'computeHostId', None, None, ), # 3 + (4, TType.STRING, 'executablePath', None, None, ), # 4 + (5, TType.I32, 'parallelism', None, 0, ), # 5 + (6, TType.STRING, 'appDeploymentDescription', None, None, ), # 6 + (7, TType.LIST, 'moduleLoadCmds', (TType.STRING,None), None, ), # 7 + (8, TType.LIST, 'libPrependPaths', (TType.STRUCT,(SetEnvPaths, SetEnvPaths.thrift_spec)), None, ), # 8 + (9, TType.LIST, 'libAppendPaths', (TType.STRUCT,(SetEnvPaths, SetEnvPaths.thrift_spec)), None, ), # 9 + (10, TType.LIST, 'setEnvironment', (TType.STRUCT,(SetEnvPaths, SetEnvPaths.thrift_spec)), None, ), # 10 + (11, TType.LIST, 'preJobCommands', (TType.STRING,None), None, ), # 11 + (12, TType.LIST, 'postJobCommands', (TType.STRING,None), None, ), # 12 + ) + + def __init__(self, appDeploymentId=thrift_spec[1][4], appModuleId=None, computeHostId=None, executablePath=None, parallelism=thrift_spec[5][4], appDeploymentDescription=None, moduleLoadCmds=None, libPrependPaths=None, libAppendPaths=None, setEnvironment=None, preJobCommands=None, postJobCommands=None,): + self.appDeploymentId = appDeploymentId + self.appModuleId = appModuleId + self.computeHostId = computeHostId + self.executablePath = executablePath + self.parallelism = parallelism + self.appDeploymentDescription = appDeploymentDescription + self.moduleLoadCmds = moduleLoadCmds + self.libPrependPaths = libPrependPaths + self.libAppendPaths = libAppendPaths + self.setEnvironment = setEnvironment + self.preJobCommands = preJobCommands + self.postJobCommands = postJobCommands + + 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.appDeploymentId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appModuleId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.computeHostId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.executablePath = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.I32: + self.parallelism = iprot.readI32(); + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.appDeploymentDescription = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.LIST: + self.moduleLoadCmds = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in xrange(_size0): + _elem5 = iprot.readString(); + self.moduleLoadCmds.append(_elem5) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.LIST: + self.libPrependPaths = [] + (_etype9, _size6) = iprot.readListBegin() + for _i10 in xrange(_size6): + _elem11 = SetEnvPaths() + _elem11.read(iprot) + self.libPrependPaths.append(_elem11) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.LIST: + self.libAppendPaths = [] + (_etype15, _size12) = iprot.readListBegin() + for _i16 in xrange(_size12): + _elem17 = SetEnvPaths() + _elem17.read(iprot) + self.libAppendPaths.append(_elem17) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.LIST: + self.setEnvironment = [] + (_etype21, _size18) = iprot.readListBegin() + for _i22 in xrange(_size18): + _elem23 = SetEnvPaths() + _elem23.read(iprot) + self.setEnvironment.append(_elem23) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.LIST: + self.preJobCommands = [] + (_etype27, _size24) = iprot.readListBegin() + for _i28 in xrange(_size24): + _elem29 = iprot.readString(); + self.preJobCommands.append(_elem29) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.LIST: + self.postJobCommands = [] + (_etype33, _size30) = iprot.readListBegin() + for _i34 in xrange(_size30): + _elem35 = iprot.readString(); + self.postJobCommands.append(_elem35) + 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('ApplicationDeploymentDescription') + if self.appDeploymentId is not None: + oprot.writeFieldBegin('appDeploymentId', TType.STRING, 1) + oprot.writeString(self.appDeploymentId) + oprot.writeFieldEnd() + if self.appModuleId is not None: + oprot.writeFieldBegin('appModuleId', TType.STRING, 2) + oprot.writeString(self.appModuleId) + oprot.writeFieldEnd() + if self.computeHostId is not None: + oprot.writeFieldBegin('computeHostId', TType.STRING, 3) + oprot.writeString(self.computeHostId) + oprot.writeFieldEnd() + if self.executablePath is not None: + oprot.writeFieldBegin('executablePath', TType.STRING, 4) + oprot.writeString(self.executablePath) + oprot.writeFieldEnd() + if self.parallelism is not None: + oprot.writeFieldBegin('parallelism', TType.I32, 5) + oprot.writeI32(self.parallelism) + oprot.writeFieldEnd() + if self.appDeploymentDescription is not None: + oprot.writeFieldBegin('appDeploymentDescription', TType.STRING, 6) + oprot.writeString(self.appDeploymentDescription) + oprot.writeFieldEnd() + if self.moduleLoadCmds is not None: + oprot.writeFieldBegin('moduleLoadCmds', TType.LIST, 7) + oprot.writeListBegin(TType.STRING, len(self.moduleLoadCmds)) + for iter36 in self.moduleLoadCmds: + oprot.writeString(iter36) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.libPrependPaths is not None: + oprot.writeFieldBegin('libPrependPaths', TType.LIST, 8) + oprot.writeListBegin(TType.STRUCT, len(self.libPrependPaths)) + for iter37 in self.libPrependPaths: + iter37.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.libAppendPaths is not None: + oprot.writeFieldBegin('libAppendPaths', TType.LIST, 9) + oprot.writeListBegin(TType.STRUCT, len(self.libAppendPaths)) + for iter38 in self.libAppendPaths: + iter38.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.setEnvironment is not None: + oprot.writeFieldBegin('setEnvironment', TType.LIST, 10) + oprot.writeListBegin(TType.STRUCT, len(self.setEnvironment)) + for iter39 in self.setEnvironment: + iter39.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.preJobCommands is not None: + oprot.writeFieldBegin('preJobCommands', TType.LIST, 11) + oprot.writeListBegin(TType.STRING, len(self.preJobCommands)) + for iter40 in self.preJobCommands: + oprot.writeString(iter40) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.postJobCommands is not None: + oprot.writeFieldBegin('postJobCommands', TType.LIST, 12) + oprot.writeListBegin(TType.STRING, len(self.postJobCommands)) + for iter41 in self.postJobCommands: + oprot.writeString(iter41) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.appDeploymentId is None: + raise TProtocol.TProtocolException(message='Required field appDeploymentId is unset!') + if self.appModuleId is None: + raise TProtocol.TProtocolException(message='Required field appModuleId is unset!') + if self.computeHostId is None: + raise TProtocol.TProtocolException(message='Required field computeHostId is unset!') + if self.executablePath is None: + raise TProtocol.TProtocolException(message='Required field executablePath is unset!') + if self.parallelism is None: + raise TProtocol.TProtocolException(message='Required field parallelism is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __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/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/constants.py new file mode 100644 index 0000000..249ecf4 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 * + +DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS" http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/ttypes.py new file mode 100644 index 0000000..942ff8a --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/appinterface/ttypes.py @@ -0,0 +1,600 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + +class DataType: + """ + Data Types supported in Airavata. The primitive data types + + """ + STRING = 0 + INTEGER = 1 + FLOAT = 2 + URI = 3 + STDOUT = 4 + STDERR = 5 + + _VALUES_TO_NAMES = { + 0: "STRING", + 1: "INTEGER", + 2: "FLOAT", + 3: "URI", + 4: "STDOUT", + 5: "STDERR", + } + + _NAMES_TO_VALUES = { + "STRING": 0, + "INTEGER": 1, + "FLOAT": 2, + "URI": 3, + "STDOUT": 4, + "STDERR": 5, + } + + +class InputDataObjectType: + """ + 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 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.STRING, 'value', None, None, ), # 2 + (3, TType.I32, 'type', None, None, ), # 3 + (4, TType.STRING, 'applicationArgument', None, None, ), # 4 + (5, TType.BOOL, 'standardInput', None, False, ), # 5 + (6, TType.STRING, 'userFriendlyDescription', None, None, ), # 6 + (7, TType.STRING, 'metaData', None, 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, False, ), # 11 + ) + + def __init__(self, name=None, value=None, type=None, applicationArgument=None, standardInput=thrift_spec[5][4], userFriendlyDescription=None, metaData=None, inputOrder=None, isRequired=None, requiredToAddedToCommandLine=None, dataStaged=thrift_spec[11][4],): + 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 + + 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.name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = 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(); + 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(); + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.metaData = 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) + 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('InputDataObjectType') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(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) + 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) + oprot.writeFieldEnd() + if self.metaData is not None: + oprot.writeFieldBegin('metaData', TType.STRING, 7) + oprot.writeString(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() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.name is None: + raise TProtocol.TProtocolException(message='Required field name is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class OutputDataObjectType: + """ + 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 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.STRING, 'value', None, None, ), # 2 + (3, TType.I32, 'type', None, None, ), # 3 + (4, TType.STRING, 'applicationArgument', None, 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', None, None, ), # 8 + (9, TType.STRING, 'searchQuery', None, None, ), # 9 + ) + + def __init__(self, name=None, value=None, type=None, applicationArgument=None, isRequired=None, requiredToAddedToCommandLine=None, dataMovement=None, location=None, searchQuery=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 + + 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.name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = 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(); + 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(); + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.STRING: + self.searchQuery = 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('OutputDataObjectType') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(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) + 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) + oprot.writeFieldEnd() + if self.searchQuery is not None: + oprot.writeFieldBegin('searchQuery', TType.STRING, 9) + oprot.writeString(self.searchQuery) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.name is None: + raise TProtocol.TProtocolException(message='Required field name is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ApplicationInterfaceDescription: + """ + Application Interface Description + + applicationModules: + Associate all application modules with versions which interface is applicable to. + + applicationInputs: + Inputs to be passed to the application + + applicationOutputs: + Outputs generated from the application + + + Attributes: + - applicationInterfaceId + - applicationName + - applicationDescription + - applicationModules + - applicationInputs + - applicationOutputs + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'applicationInterfaceId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'applicationName', None, None, ), # 2 + (3, TType.STRING, 'applicationDescription', None, None, ), # 3 + (4, TType.LIST, 'applicationModules', (TType.STRING,None), None, ), # 4 + (5, TType.LIST, 'applicationInputs', (TType.STRUCT,(InputDataObjectType, InputDataObjectType.thrift_spec)), None, ), # 5 + (6, TType.LIST, 'applicationOutputs', (TType.STRUCT,(OutputDataObjectType, OutputDataObjectType.thrift_spec)), None, ), # 6 + ) + + def __init__(self, applicationInterfaceId=thrift_spec[1][4], applicationName=None, applicationDescription=None, applicationModules=None, applicationInputs=None, applicationOutputs=None,): + self.applicationInterfaceId = applicationInterfaceId + self.applicationName = applicationName + self.applicationDescription = applicationDescription + self.applicationModules = applicationModules + self.applicationInputs = applicationInputs + self.applicationOutputs = applicationOutputs + + 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.applicationInterfaceId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.applicationName = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.applicationDescription = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.applicationModules = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in xrange(_size0): + _elem5 = iprot.readString(); + self.applicationModules.append(_elem5) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.applicationInputs = [] + (_etype9, _size6) = iprot.readListBegin() + for _i10 in xrange(_size6): + _elem11 = InputDataObjectType() + _elem11.read(iprot) + self.applicationInputs.append(_elem11) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.LIST: + self.applicationOutputs = [] + (_etype15, _size12) = iprot.readListBegin() + for _i16 in xrange(_size12): + _elem17 = OutputDataObjectType() + _elem17.read(iprot) + self.applicationOutputs.append(_elem17) + 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('ApplicationInterfaceDescription') + if self.applicationInterfaceId is not None: + oprot.writeFieldBegin('applicationInterfaceId', TType.STRING, 1) + oprot.writeString(self.applicationInterfaceId) + oprot.writeFieldEnd() + if self.applicationName is not None: + oprot.writeFieldBegin('applicationName', TType.STRING, 2) + oprot.writeString(self.applicationName) + oprot.writeFieldEnd() + if self.applicationDescription is not None: + oprot.writeFieldBegin('applicationDescription', TType.STRING, 3) + oprot.writeString(self.applicationDescription) + oprot.writeFieldEnd() + if self.applicationModules is not None: + oprot.writeFieldBegin('applicationModules', TType.LIST, 4) + oprot.writeListBegin(TType.STRING, len(self.applicationModules)) + for iter18 in self.applicationModules: + oprot.writeString(iter18) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.applicationInputs is not None: + oprot.writeFieldBegin('applicationInputs', TType.LIST, 5) + oprot.writeListBegin(TType.STRUCT, len(self.applicationInputs)) + for iter19 in self.applicationInputs: + iter19.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.applicationOutputs is not None: + oprot.writeFieldBegin('applicationOutputs', TType.LIST, 6) + oprot.writeListBegin(TType.STRUCT, len(self.applicationOutputs)) + for iter20 in self.applicationOutputs: + iter20.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.applicationInterfaceId is None: + raise TProtocol.TProtocolException(message='Required field applicationInterfaceId is unset!') + if self.applicationName is None: + raise TProtocol.TProtocolException(message='Required field applicationName is unset!') + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __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/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/constants.py new file mode 100644 index 0000000..249ecf4 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/computeresource/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# 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 * + +DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS"
