http://git-wip-us.apache.org/repos/asf/airavata/blob/edfbbfe0/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py index a73f2c1..1cae97f 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py @@ -2846,6 +2846,39 @@ class Iface: """ pass + def shareResourceWithUsers(self, authzToken, resourceId, resourceType, userPermissionList): + """ + Group Manager and Data Sharing Related API methods + + + Parameters: + - authzToken + - resourceId + - resourceType + - userPermissionList + """ + pass + + def revokeSharingOfResourceFromUsers(self, authzToken, resourceId, resourceType, userPermissionList): + """ + Parameters: + - authzToken + - resourceId + - resourceType + - userPermissionList + """ + pass + + def getAllAccessibleUsers(self, authzToken, resourceId, resourceType, permissionType): + """ + Parameters: + - authzToken + - resourceId + - resourceType + - permissionType + """ + pass + class Client(Iface): def __init__(self, iprot, oprot=None): @@ -10418,6 +10451,144 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "getChildDataProducts failed: unknown result") + def shareResourceWithUsers(self, authzToken, resourceId, resourceType, userPermissionList): + """ + Group Manager and Data Sharing Related API methods + + + Parameters: + - authzToken + - resourceId + - resourceType + - userPermissionList + """ + self.send_shareResourceWithUsers(authzToken, resourceId, resourceType, userPermissionList) + return self.recv_shareResourceWithUsers() + + def send_shareResourceWithUsers(self, authzToken, resourceId, resourceType, userPermissionList): + self._oprot.writeMessageBegin('shareResourceWithUsers', TMessageType.CALL, self._seqid) + args = shareResourceWithUsers_args() + args.authzToken = authzToken + args.resourceId = resourceId + args.resourceType = resourceType + args.userPermissionList = userPermissionList + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_shareResourceWithUsers(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = shareResourceWithUsers_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "shareResourceWithUsers failed: unknown result") + + def revokeSharingOfResourceFromUsers(self, authzToken, resourceId, resourceType, userPermissionList): + """ + Parameters: + - authzToken + - resourceId + - resourceType + - userPermissionList + """ + self.send_revokeSharingOfResourceFromUsers(authzToken, resourceId, resourceType, userPermissionList) + return self.recv_revokeSharingOfResourceFromUsers() + + def send_revokeSharingOfResourceFromUsers(self, authzToken, resourceId, resourceType, userPermissionList): + self._oprot.writeMessageBegin('revokeSharingOfResourceFromUsers', TMessageType.CALL, self._seqid) + args = revokeSharingOfResourceFromUsers_args() + args.authzToken = authzToken + args.resourceId = resourceId + args.resourceType = resourceType + args.userPermissionList = userPermissionList + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_revokeSharingOfResourceFromUsers(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = revokeSharingOfResourceFromUsers_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "revokeSharingOfResourceFromUsers failed: unknown result") + + def getAllAccessibleUsers(self, authzToken, resourceId, resourceType, permissionType): + """ + Parameters: + - authzToken + - resourceId + - resourceType + - permissionType + """ + self.send_getAllAccessibleUsers(authzToken, resourceId, resourceType, permissionType) + return self.recv_getAllAccessibleUsers() + + def send_getAllAccessibleUsers(self, authzToken, resourceId, resourceType, permissionType): + self._oprot.writeMessageBegin('getAllAccessibleUsers', TMessageType.CALL, self._seqid) + args = getAllAccessibleUsers_args() + args.authzToken = authzToken + args.resourceId = resourceId + args.resourceType = resourceType + args.permissionType = permissionType + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllAccessibleUsers(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllAccessibleUsers_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllAccessibleUsers failed: unknown result") + class Processor(Iface, TProcessor): def __init__(self, handler): @@ -10564,6 +10735,9 @@ class Processor(Iface, TProcessor): self._processMap["registerReplicaLocation"] = Processor.process_registerReplicaLocation self._processMap["getParentDataProduct"] = Processor.process_getParentDataProduct self._processMap["getChildDataProducts"] = Processor.process_getChildDataProducts + self._processMap["shareResourceWithUsers"] = Processor.process_shareResourceWithUsers + self._processMap["revokeSharingOfResourceFromUsers"] = Processor.process_revokeSharingOfResourceFromUsers + self._processMap["getAllAccessibleUsers"] = Processor.process_getAllAccessibleUsers def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -14960,6 +15134,99 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_shareResourceWithUsers(self, seqid, iprot, oprot): + args = shareResourceWithUsers_args() + args.read(iprot) + iprot.readMessageEnd() + result = shareResourceWithUsers_result() + try: + result.success = self._handler.shareResourceWithUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY + result.ae = ae + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("shareResourceWithUsers", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_revokeSharingOfResourceFromUsers(self, seqid, iprot, oprot): + args = revokeSharingOfResourceFromUsers_args() + args.read(iprot) + iprot.readMessageEnd() + result = revokeSharingOfResourceFromUsers_result() + try: + result.success = self._handler.revokeSharingOfResourceFromUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY + result.ae = ae + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("revokeSharingOfResourceFromUsers", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getAllAccessibleUsers(self, seqid, iprot, oprot): + args = getAllAccessibleUsers_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllAccessibleUsers_result() + try: + result.success = self._handler.getAllAccessibleUsers(args.authzToken, args.resourceId, args.resourceType, args.permissionType) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY + result.ae = ae + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllAccessibleUsers", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + # HELPER FUNCTIONS AND STRUCTURES @@ -22657,8 +22924,394 @@ class updateExperiment_args: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRUCT: - self.experiment = apache.airavata.model.experiment.ttypes.ExperimentModel() - self.experiment.read(iprot) + self.experiment = apache.airavata.model.experiment.ttypes.ExperimentModel() + self.experiment.read(iprot) + 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('updateExperiment_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.airavataExperimentId is not None: + oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) + oprot.writeString(self.airavataExperimentId) + oprot.writeFieldEnd() + if self.experiment is not None: + oprot.writeFieldBegin('experiment', TType.STRUCT, 3) + self.experiment.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.airavataExperimentId is None: + raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') + if self.experiment is None: + raise TProtocol.TProtocolException(message='Required field experiment is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.airavataExperimentId) + value = (value * 31) ^ hash(self.experiment) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateExperiment_result: + """ + Attributes: + - ire + - enf + - ace + - ase + - ae + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 4 + (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 + ) + + def __init__(self, ire=None, enf=None, ace=None, ase=None, ae=None,): + self.ire = ire + self.enf = enf + self.ace = ace + self.ase = ase + self.ae = ae + + 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.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.enf = apache.airavata.api.error.ttypes.ExperimentNotFoundException() + self.enf.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + 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('updateExperiment_result') + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.enf is not None: + oprot.writeFieldBegin('enf', TType.STRUCT, 2) + self.enf.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 3) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 4) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 5) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.enf) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateExperimentConfiguration_args: + """ + Attributes: + - authzToken + - airavataExperimentId + - userConfiguration + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 + (3, TType.STRUCT, 'userConfiguration', (apache.airavata.model.experiment.ttypes.UserConfigurationDataModel, apache.airavata.model.experiment.ttypes.UserConfigurationDataModel.thrift_spec), None, ), # 3 + ) + + def __init__(self, authzToken=None, airavataExperimentId=None, userConfiguration=None,): + self.authzToken = authzToken + self.airavataExperimentId = airavataExperimentId + self.userConfiguration = userConfiguration + + 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.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.airavataExperimentId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.userConfiguration = apache.airavata.model.experiment.ttypes.UserConfigurationDataModel() + self.userConfiguration.read(iprot) + 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('updateExperimentConfiguration_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.airavataExperimentId is not None: + oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) + oprot.writeString(self.airavataExperimentId) + oprot.writeFieldEnd() + if self.userConfiguration is not None: + oprot.writeFieldBegin('userConfiguration', TType.STRUCT, 3) + self.userConfiguration.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.airavataExperimentId is None: + raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') + if self.userConfiguration is None: + raise TProtocol.TProtocolException(message='Required field userConfiguration is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.airavataExperimentId) + value = (value * 31) ^ hash(self.userConfiguration) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateExperimentConfiguration_result: + """ + Attributes: + - ae + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 1 + ) + + def __init__(self, ae=None,): + self.ae = ae + + 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.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + 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('updateExperimentConfiguration_result') + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 1) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateResourceScheduleing_args: + """ + Attributes: + - authzToken + - airavataExperimentId + - resourceScheduling + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 + (3, TType.STRUCT, 'resourceScheduling', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ), # 3 + ) + + def __init__(self, authzToken=None, airavataExperimentId=None, resourceScheduling=None,): + self.authzToken = authzToken + self.airavataExperimentId = airavataExperimentId + self.resourceScheduling = resourceScheduling + + 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.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.airavataExperimentId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.resourceScheduling = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel() + self.resourceScheduling.read(iprot) else: iprot.skip(ftype) else: @@ -22670,7 +23323,7 @@ class updateExperiment_args: 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('updateExperiment_args') + oprot.writeStructBegin('updateResourceScheduleing_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -22679,9 +23332,9 @@ class updateExperiment_args: oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) oprot.writeString(self.airavataExperimentId) oprot.writeFieldEnd() - if self.experiment is not None: - oprot.writeFieldBegin('experiment', TType.STRUCT, 3) - self.experiment.write(oprot) + if self.resourceScheduling is not None: + oprot.writeFieldBegin('resourceScheduling', TType.STRUCT, 3) + self.resourceScheduling.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -22691,8 +23344,8 @@ class updateExperiment_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.airavataExperimentId is None: raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') - if self.experiment is None: - raise TProtocol.TProtocolException(message='Required field experiment is unset!') + if self.resourceScheduling is None: + raise TProtocol.TProtocolException(message='Required field resourceScheduling is unset!') return @@ -22700,7 +23353,7 @@ class updateExperiment_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.airavataExperimentId) - value = (value * 31) ^ hash(self.experiment) + value = (value * 31) ^ hash(self.resourceScheduling) return value def __repr__(self): @@ -22714,30 +23367,18 @@ class updateExperiment_args: def __ne__(self, other): return not (self == other) -class updateExperiment_result: +class updateResourceScheduleing_result: """ Attributes: - - ire - - enf - - ace - - ase - ae """ thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 - (4, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 4 - (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 + (1, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 1 ) - def __init__(self, ire=None, enf=None, ace=None, ase=None, ae=None,): - self.ire = ire - self.enf = enf - self.ace = ace - self.ase = ase + def __init__(self, ae=None,): self.ae = ae def read(self, iprot): @@ -22751,30 +23392,6 @@ class updateExperiment_result: break if fid == 1: if ftype == TType.STRUCT: - self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() - self.ire.read(iprot) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.enf = apache.airavata.api.error.ttypes.ExperimentNotFoundException() - self.enf.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRUCT: self.ae = apache.airavata.api.error.ttypes.AuthorizationException() self.ae.read(iprot) else: @@ -22788,25 +23405,9 @@ class updateExperiment_result: 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('updateExperiment_result') - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.enf is not None: - oprot.writeFieldBegin('enf', TType.STRUCT, 2) - self.enf.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 3) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 4) - self.ase.write(oprot) - oprot.writeFieldEnd() + oprot.writeStructBegin('updateResourceScheduleing_result') if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 5) + oprot.writeFieldBegin('ae', TType.STRUCT, 1) self.ae.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22818,10 +23419,6 @@ class updateExperiment_result: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.ire) - value = (value * 31) ^ hash(self.enf) - value = (value * 31) ^ hash(self.ace) - value = (value * 31) ^ hash(self.ase) value = (value * 31) ^ hash(self.ae) return value @@ -22836,25 +23433,22 @@ class updateExperiment_result: def __ne__(self, other): return not (self == other) -class updateExperimentConfiguration_args: +class validateExperiment_args: """ Attributes: - authzToken - airavataExperimentId - - userConfiguration """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 - (3, TType.STRUCT, 'userConfiguration', (apache.airavata.model.experiment.ttypes.UserConfigurationDataModel, apache.airavata.model.experiment.ttypes.UserConfigurationDataModel.thrift_spec), None, ), # 3 ) - def __init__(self, authzToken=None, airavataExperimentId=None, userConfiguration=None,): + def __init__(self, authzToken=None, airavataExperimentId=None,): self.authzToken = authzToken self.airavataExperimentId = airavataExperimentId - self.userConfiguration = userConfiguration 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: @@ -22876,12 +23470,6 @@ class updateExperimentConfiguration_args: self.airavataExperimentId = iprot.readString() else: iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.userConfiguration = apache.airavata.model.experiment.ttypes.UserConfigurationDataModel() - self.userConfiguration.read(iprot) - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -22891,7 +23479,7 @@ class updateExperimentConfiguration_args: 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('updateExperimentConfiguration_args') + oprot.writeStructBegin('validateExperiment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -22900,10 +23488,6 @@ class updateExperimentConfiguration_args: oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) oprot.writeString(self.airavataExperimentId) oprot.writeFieldEnd() - if self.userConfiguration is not None: - oprot.writeFieldBegin('userConfiguration', TType.STRUCT, 3) - self.userConfiguration.write(oprot) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -22912,8 +23496,6 @@ class updateExperimentConfiguration_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.airavataExperimentId is None: raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') - if self.userConfiguration is None: - raise TProtocol.TProtocolException(message='Required field userConfiguration is unset!') return @@ -22921,7 +23503,6 @@ class updateExperimentConfiguration_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.airavataExperimentId) - value = (value * 31) ^ hash(self.userConfiguration) return value def __repr__(self): @@ -22935,18 +23516,32 @@ class updateExperimentConfiguration_args: def __ne__(self, other): return not (self == other) -class updateExperimentConfiguration_result: +class validateExperiment_result: """ Attributes: + - success + - ire + - enf + - ace + - ase - ae """ thrift_spec = ( - None, # 0 - (1, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 1 + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 4 + (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 ) - def __init__(self, ae=None,): + def __init__(self, success=None, ire=None, enf=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.enf = enf + self.ace = ace + self.ase = ase self.ae = ae def read(self, iprot): @@ -22958,7 +23553,36 @@ class updateExperimentConfiguration_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 1: + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.enf = apache.airavata.api.error.ttypes.ExperimentNotFoundException() + self.enf.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 5: if ftype == TType.STRUCT: self.ae = apache.airavata.api.error.ttypes.AuthorizationException() self.ae.read(iprot) @@ -22973,9 +23597,29 @@ class updateExperimentConfiguration_result: 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('updateExperimentConfiguration_result') + oprot.writeStructBegin('validateExperiment_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.enf is not None: + oprot.writeFieldBegin('enf', TType.STRUCT, 2) + self.enf.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 3) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 4) + self.ase.write(oprot) + oprot.writeFieldEnd() if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 1) + oprot.writeFieldBegin('ae', TType.STRUCT, 5) self.ae.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22987,6 +23631,11 @@ class updateExperimentConfiguration_result: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.enf) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) value = (value * 31) ^ hash(self.ae) return value @@ -23001,25 +23650,25 @@ class updateExperimentConfiguration_result: def __ne__(self, other): return not (self == other) -class updateResourceScheduleing_args: +class launchExperiment_args: """ Attributes: - authzToken - airavataExperimentId - - resourceScheduling + - gatewayId """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 - (3, TType.STRUCT, 'resourceScheduling', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ), # 3 + (3, TType.STRING, 'gatewayId', None, None, ), # 3 ) - def __init__(self, authzToken=None, airavataExperimentId=None, resourceScheduling=None,): + def __init__(self, authzToken=None, airavataExperimentId=None, gatewayId=None,): self.authzToken = authzToken self.airavataExperimentId = airavataExperimentId - self.resourceScheduling = resourceScheduling + self.gatewayId = gatewayId 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: @@ -23042,9 +23691,8 @@ class updateResourceScheduleing_args: else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.STRUCT: - self.resourceScheduling = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel() - self.resourceScheduling.read(iprot) + if ftype == TType.STRING: + self.gatewayId = iprot.readString() else: iprot.skip(ftype) else: @@ -23056,7 +23704,7 @@ class updateResourceScheduleing_args: 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('updateResourceScheduleing_args') + oprot.writeStructBegin('launchExperiment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -23065,9 +23713,9 @@ class updateResourceScheduleing_args: oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) oprot.writeString(self.airavataExperimentId) oprot.writeFieldEnd() - if self.resourceScheduling is not None: - oprot.writeFieldBegin('resourceScheduling', TType.STRUCT, 3) - self.resourceScheduling.write(oprot) + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 3) + oprot.writeString(self.gatewayId) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -23077,8 +23725,8 @@ class updateResourceScheduleing_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.airavataExperimentId is None: raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') - if self.resourceScheduling is None: - raise TProtocol.TProtocolException(message='Required field resourceScheduling is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') return @@ -23086,7 +23734,7 @@ class updateResourceScheduleing_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.airavataExperimentId) - value = (value * 31) ^ hash(self.resourceScheduling) + value = (value * 31) ^ hash(self.gatewayId) return value def __repr__(self): @@ -23100,18 +23748,30 @@ class updateResourceScheduleing_args: def __ne__(self, other): return not (self == other) -class updateResourceScheduleing_result: +class launchExperiment_result: """ Attributes: + - ire + - enf + - ace + - ase - ae """ thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 1 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 4 + (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 ) - def __init__(self, ae=None,): + def __init__(self, ire=None, enf=None, ace=None, ase=None, ae=None,): + self.ire = ire + self.enf = enf + self.ace = ace + self.ase = ase self.ae = ae def read(self, iprot): @@ -23125,6 +23785,30 @@ class updateResourceScheduleing_result: break if fid == 1: if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.enf = apache.airavata.api.error.ttypes.ExperimentNotFoundException() + self.enf.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRUCT: self.ae = apache.airavata.api.error.ttypes.AuthorizationException() self.ae.read(iprot) else: @@ -23138,9 +23822,25 @@ class updateResourceScheduleing_result: 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('updateResourceScheduleing_result') + oprot.writeStructBegin('launchExperiment_result') + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.enf is not None: + oprot.writeFieldBegin('enf', TType.STRUCT, 2) + self.enf.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 3) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 4) + self.ase.write(oprot) + oprot.writeFieldEnd() if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 1) + oprot.writeFieldBegin('ae', TType.STRUCT, 5) self.ae.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23152,6 +23852,10 @@ class updateResourceScheduleing_result: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.enf) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) value = (value * 31) ^ hash(self.ae) return value @@ -23166,7 +23870,7 @@ class updateResourceScheduleing_result: def __ne__(self, other): return not (self == other) -class validateExperiment_args: +class getExperimentStatus_args: """ Attributes: - authzToken @@ -23212,7 +23916,7 @@ class validateExperiment_args: 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('validateExperiment_args') + oprot.writeStructBegin('getExperimentStatus_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -23249,7 +23953,7 @@ class validateExperiment_args: def __ne__(self, other): return not (self == other) -class validateExperiment_result: +class getExperimentStatus_result: """ Attributes: - success @@ -23261,7 +23965,7 @@ class validateExperiment_result: """ thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.STRUCT, 'success', (apache.airavata.model.status.ttypes.ExperimentStatus, apache.airavata.model.status.ttypes.ExperimentStatus.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -23287,8 +23991,9 @@ class validateExperiment_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool() + if ftype == TType.STRUCT: + self.success = apache.airavata.model.status.ttypes.ExperimentStatus() + self.success.read(iprot) else: iprot.skip(ftype) elif fid == 1: @@ -23330,10 +24035,10 @@ class validateExperiment_result: 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('validateExperiment_result') + oprot.writeStructBegin('getExperimentStatus_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -23383,25 +24088,22 @@ class validateExperiment_result: def __ne__(self, other): return not (self == other) -class launchExperiment_args: +class getExperimentOutputs_args: """ Attributes: - authzToken - airavataExperimentId - - gatewayId """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 - (3, TType.STRING, 'gatewayId', None, None, ), # 3 ) - def __init__(self, authzToken=None, airavataExperimentId=None, gatewayId=None,): + def __init__(self, authzToken=None, airavataExperimentId=None,): self.authzToken = authzToken self.airavataExperimentId = airavataExperimentId - self.gatewayId = gatewayId 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: @@ -23423,11 +24125,6 @@ class launchExperiment_args: self.airavataExperimentId = iprot.readString() else: iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.gatewayId = iprot.readString() - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -23437,7 +24134,7 @@ class launchExperiment_args: 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('launchExperiment_args') + oprot.writeStructBegin('getExperimentOutputs_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -23446,10 +24143,6 @@ class launchExperiment_args: oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) oprot.writeString(self.airavataExperimentId) oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 3) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -23458,8 +24151,6 @@ class launchExperiment_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.airavataExperimentId is None: raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') - if self.gatewayId is None: - raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') return @@ -23467,7 +24158,6 @@ class launchExperiment_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.airavataExperimentId) - value = (value * 31) ^ hash(self.gatewayId) return value def __repr__(self): @@ -23481,9 +24171,10 @@ class launchExperiment_args: def __ne__(self, other): return not (self == other) -class launchExperiment_result: +class getExperimentOutputs_result: """ Attributes: + - success - ire - enf - ace @@ -23492,7 +24183,7 @@ class launchExperiment_result: """ thrift_spec = ( - None, # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -23500,7 +24191,8 @@ class launchExperiment_result: (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 ) - def __init__(self, ire=None, enf=None, ace=None, ase=None, ae=None,): + def __init__(self, success=None, ire=None, enf=None, ace=None, ase=None, ae=None,): + self.success = success self.ire = ire self.enf = enf self.ace = ace @@ -23516,7 +24208,18 @@ class launchExperiment_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 1: + if fid == 0: + if ftype == TType.LIST: + self.success = [] + (_etype95, _size92) = iprot.readListBegin() + for _i96 in xrange(_size92): + _elem97 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem97.read(iprot) + self.success.append(_elem97) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: if ftype == TType.STRUCT: self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() self.ire.read(iprot) @@ -23555,7 +24258,14 @@ class launchExperiment_result: 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('launchExperiment_result') + oprot.writeStructBegin('getExperimentOutputs_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter98 in self.success: + iter98.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) self.ire.write(oprot) @@ -23585,6 +24295,7 @@ class launchExperiment_result: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.ire) value = (value * 31) ^ hash(self.enf) value = (value * 31) ^ hash(self.ace) @@ -23603,7 +24314,7 @@ class launchExperiment_result: def __ne__(self, other): return not (self == other) -class getExperimentStatus_args: +class getIntermediateOutputs_args: """ Attributes: - authzToken @@ -23649,7 +24360,7 @@ class getExperimentStatus_args: 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('getExperimentStatus_args') + oprot.writeStructBegin('getIntermediateOutputs_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -23686,7 +24397,7 @@ class getExperimentStatus_args: def __ne__(self, other): return not (self == other) -class getExperimentStatus_result: +class getIntermediateOutputs_result: """ Attributes: - success @@ -23698,7 +24409,7 @@ class getExperimentStatus_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (apache.airavata.model.status.ttypes.ExperimentStatus, apache.airavata.model.status.ttypes.ExperimentStatus.thrift_spec), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -23724,9 +24435,14 @@ class getExperimentStatus_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.STRUCT: - self.success = apache.airavata.model.status.ttypes.ExperimentStatus() - self.success.read(iprot) + if ftype == TType.LIST: + self.success = [] + (_etype102, _size99) = iprot.readListBegin() + for _i103 in xrange(_size99): + _elem104 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem104.read(iprot) + self.success.append(_elem104) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 1: @@ -23768,10 +24484,13 @@ class getExperimentStatus_result: 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('getExperimentStatus_result') + oprot.writeStructBegin('getIntermediateOutputs_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter105 in self.success: + iter105.write(oprot) + oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -23821,7 +24540,7 @@ class getExperimentStatus_result: def __ne__(self, other): return not (self == other) -class getExperimentOutputs_args: +class getJobStatuses_args: """ Attributes: - authzToken @@ -23867,7 +24586,7 @@ class getExperimentOutputs_args: 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('getExperimentOutputs_args') + oprot.writeStructBegin('getJobStatuses_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -23904,7 +24623,7 @@ class getExperimentOutputs_args: def __ne__(self, other): return not (self == other) -class getExperimentOutputs_result: +class getJobStatuses_result: """ Attributes: - success @@ -23916,7 +24635,7 @@ class getExperimentOutputs_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 0 + (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(apache.airavata.model.status.ttypes.JobStatus, apache.airavata.model.status.ttypes.JobStatus.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -23942,14 +24661,15 @@ class getExperimentOutputs_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype95, _size92) = iprot.readListBegin() - for _i96 in xrange(_size92): - _elem97 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem97.read(iprot) - self.success.append(_elem97) - iprot.readListEnd() + if ftype == TType.MAP: + self.success = {} + (_ktype107, _vtype108, _size106 ) = iprot.readMapBegin() + for _i110 in xrange(_size106): + _key111 = iprot.readString() + _val112 = apache.airavata.model.status.ttypes.JobStatus() + _val112.read(iprot) + self.success[_key111] = _val112 + iprot.readMapEnd() else: iprot.skip(ftype) elif fid == 1: @@ -23991,13 +24711,14 @@ class getExperimentOutputs_result: 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('getExperimentOutputs_result') + oprot.writeStructBegin('getJobStatuses_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter98 in self.success: - iter98.write(oprot) - oprot.writeListEnd() + oprot.writeFieldBegin('success', TType.MAP, 0) + oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) + for kiter113,viter114 in self.success.items(): + oprot.writeString(kiter113) + viter114.write(oprot) + oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -24047,7 +24768,7 @@ class getExperimentOutputs_result: def __ne__(self, other): return not (self == other) -class getIntermediateOutputs_args: +class getJobDetails_args: """ Attributes: - authzToken @@ -24093,7 +24814,7 @@ class getIntermediateOutputs_args: 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('getIntermediateOutputs_args') + oprot.writeStructBegin('getJobDetails_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -24130,7 +24851,7 @@ class getIntermediateOutputs_args: def __ne__(self, other): return not (self == other) -class getIntermediateOutputs_result: +class getJobDetails_result: """ Attributes: - success @@ -24142,7 +24863,7 @@ class getIntermediateOutputs_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.job.ttypes.JobModel, apache.airavata.model.job.ttypes.JobModel.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -24170,11 +24891,11 @@ class getIntermediateOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype102, _size99) = iprot.readListBegin() - for _i103 in xrange(_size99): - _elem104 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem104.read(iprot) - self.success.append(_elem104) + (_etype118, _size115) = iprot.readListBegin() + for _i119 in xrange(_size115): + _elem120 = apache.airavata.model.job.ttypes.JobModel() + _elem120.read(iprot) + self.success.append(_elem120) iprot.readListEnd() else: iprot.skip(ftype) @@ -24217,12 +24938,12 @@ class getIntermediateOutputs_result: 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('getIntermediateOutputs_result') + oprot.writeStructBegin('getJobDetails_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter105 in self.success: - iter105.write(oprot) + for iter121 in self.success: + iter121.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -24273,22 +24994,25 @@ class getIntermediateOutputs_result: def __ne__(self, other): return not (self == other) -class getJobStatuses_args: +class cloneExperiment_args: """ Attributes: - authzToken - - airavataExperimentId + - existingExperimentID + - newExperimentName """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 + (2, TType.STRING, 'existingExperimentID', None, None, ), # 2 + (3, TType.STRING, 'newExperimentName', None, None, ), # 3 ) - def __init__(self, authzToken=None, airavataExperimentId=None,): + def __init__(self, authzToken=None, existingExperimentID=None, newExperimentName=None,): self.authzToken = authzToken - self.airavataExperimentId = airavataExperimentId + self.existingExperimentID = existingExperimentID + self.newExperimentName = newExperimentName 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: @@ -24307,7 +25031,12 @@ class getJobStatuses_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.airavataExperimentId = iprot.readString() + self.existingExperimentID = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.newExperimentName = iprot.readString() else: iprot.skip(ftype) else: @@ -24319,14 +25048,18 @@ class getJobStatuses_args: 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('getJobStatuses_args') + oprot.writeStructBegin('cloneExperiment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.airavataExperimentId is not None: - oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) - oprot.writeString(self.airavataExperimentId) + if self.existingExperimentID is not None: + oprot.writeFieldBegin('existingExperimentID', TType.STRING, 2) + oprot.writeString(self.existingExperimentID) + oprot.writeFieldEnd() + if self.newExperimentName is not None: + oprot.writeFieldBegin('newExperimentName', TType.STRING, 3) + oprot.writeString(self.newExperimentName) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -24334,15 +25067,14 @@ class getJobStatuses_args: def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - if self.airavataExperimentId is None: - raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') return def __hash__(self): value = 17 value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.airavataExperimentId) + value = (value * 31) ^ hash(self.existingExperimentID) + value = (value * 31) ^ hash(self.newExperimentName) return value def __repr__(self): @@ -24356,7 +25088,7 @@ class getJobStatuses_args: def __ne__(self, other): return not (self == other) -class getJobStatuses_result: +class cloneExperiment_result: """ Attributes: - success @@ -24368,7 +25100,7 @@ class getJobStatuses_result: """ thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(apache.airavata.model.status.ttypes.JobStatus, apache.airavata.model.status.ttypes.JobStatus.thrift_spec)), None, ), # 0 + (0, TType.STRING, 'success', None, None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -24394,15 +25126,8 @@ class getJobStatuses_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype107, _vtype108, _size106 ) = iprot.readMapBegin() - for _i110 in xrange(_size106): - _key111 = iprot.readString() - _val112 = apache.airavata.model.status.ttypes.JobStatus() - _val112.read(iprot) - self.success[_key111] = _val112 - iprot.readMapEnd() + if ftype == TType.STRING: + self.success = iprot.readString() else: iprot.skip(ftype) elif fid == 1: @@ -24444,14 +25169,10 @@ class getJobStatuses_result: 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('getJobStatuses_result') + oprot.writeStructBegin('cloneExperiment_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter113,viter114 in self.success.items(): - oprot.writeString(kiter113) - viter114.write(oprot) - oprot.writeMapEnd() + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -24501,22 +25222,25 @@ class getJobStatuses_result: def __ne__(self, other): return not (self == other) -class getJobDetails_args: +class terminateExperiment_args: """ Attributes: - authzToken - airavataExperimentId + - gatewayId """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'airavataExperimentId', None, None, ), # 2 + (3, TType.STRING, 'gatewayId', None, None, ), # 3 ) - def __init__(self, authzToken=None, airavataExperimentId=None,): + def __init__(self, authzToken=None, airavataExperimentId=None, gatewayId=None,): self.authzToken = authzToken self.airavataExperimentId = airavataExperimentId + self.gatewayId = gatewayId 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: @@ -24538,6 +25262,11 @@ class getJobDetails_args: self.airavataExperimentId = iprot.readString() else: iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.gatewayId = iprot.readString() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -24547,7 +25276,7 @@ class getJobDetails_args: 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('getJobDetails_args') + oprot.writeStructBegin('terminateExperiment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -24556,14 +25285,16 @@ class getJobDetails_args: oprot.writeFieldBegin('airavataExperimentId', TType.STRING, 2) oprot.writeString(self.airavataExperimentId) oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 3) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - if self.airavataExperimentId is None: - raise TProtocol.TProtocolException(message='Required field airavataExperimentId is unset!') return @@ -24571,6 +25302,7 @@ class getJobDetails_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.airavataExperimentId) + value = (value * 31) ^ hash(self.gatewayId) return value def __repr__(self): @@ -24584,10 +25316,9 @@ class getJobDetails_args: def __ne__(self, other): return not (self == other) -class getJobDetails_result: +class terminateExperiment_result: """ Attributes: - - success - ire - enf - ace @@ -24596,7 +25327,7 @@ class getJobDetails_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.job.ttypes.JobModel, apache.airavata.model.job.ttypes.JobModel.thrift_spec)), None, ), # 0 + None, # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 @@ -24604,8 +25335,7 @@ class getJobDetails_result: (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 ) - def __init__(self, success=None, ire=None, enf=None, ace=None, ase=None, ae=None,): - self.success = success + def __init__(self, ire=None, enf=None, ace=None, ase=None, ae=None,): self.ire = ire self.enf = enf self.ace = ace @@ -24621,18 +25351,7 @@ class getJobDetails_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype118, _size115) = iprot.readListBegin() - for _i119 in xrange(_size115): - _elem120 = apache.airavata.model.job.ttypes.JobModel() - _elem120.read(iprot) - self.success.append(_elem120) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 1: + if fid == 1: if ftype == TType.STRUCT: self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() self.ire.read(iprot) @@ -24671,14 +25390,7 @@ class getJobDetails_result: 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('getJobDetails_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter121 in self.success: - iter121.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() + oprot.writeStructBegin('terminateExperiment_result') if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) self.ire.write(oprot) @@ -24708,7 +25420,6 @@ class getJobDetails_result: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.ire) value = (value * 31) ^ hash(self.enf) value = (value * 31) ^ hash(self.ace) @@ -24727,25 +25438,25 @@ class getJobDetails_result: def __ne__(self, other): return not (self == other) -class cloneExperiment_args: +class registerApplicationModule_args: """ Attributes: - authzToken - - existingExperimentID - - newExperimentName + - gatewayId + - applicationModule """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRING, 'existingExperimentID', None, None, ), # 2 - (3, TType.STRING, 'newExperimentName', None, None, ), # 3 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + (3, TType.STRUCT, 'applicationModule', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule.thrift_spec), None, ), # 3 ) - def __init__(self, authzToken=None, existingExperimentID=None, newExperimentName=None,): + def __init__(self, authzToken=None, gatewayId=None, applicationModule=None,): self.authzToken = authzToken - self.existingExperimentID = existingExperimentID - self.newExperimentName = newExperimentName + self.gatewayId = gatewayId + self.applicationModule = applicationModule 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: @@ -24764,12 +25475,13 @@ class cloneExperiment_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.existingExperimentID = iprot.readString() + self.gatewayId = iprot.readString() else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.STRING: - self.newExperimentName = iprot.readString() + if ftype == TType.STRUCT: + self.applicationModule = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + self.applicationModule.read(iprot) else: iprot.skip(ftype) else: @@ -24781,18 +25493,18 @@ class cloneExperiment_args: 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('cloneExperiment_args') + oprot.writeStructBegin('registerApplicationModule_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.existingExperimentID is not None: - oprot.writeFieldBegin('existingExperimentID', TType.STRING, 2) - oprot.writeString(self.existingExperimentID) + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) oprot.writeFieldEnd() - if self.newExperimentName is not None: - oprot.writeFieldBegin('newExperimentName', TType.STRING, 3) - oprot.writeString(self.newExperimentName) + if self.applicationModule is not None: + oprot.writeFieldBegin('applicationModule', TType.STRUCT, 3) + self.applicationModule.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -24800,14 +25512,18 @@ class cloneExperiment_args: def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + if self.applicationModule is None: + raise TProtocol.TProtocolException(message='Required field applicationModule is unset!') return def __hash__(self): value = 17 value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.existingExperimentID) - value = (value * 31) ^ hash(self.newExperimentName) + value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.applicationModule) return value def __repr__(self): @@ -24821,12 +25537,11 @@ class cloneExperiment_args: def __ne__(self, other): return not (self == other) -class cloneExperiment_result: +class registerApplicationModule_result: """ Attributes: - success - ire - - enf - ace - ase - ae @@ -24835,16 +25550,14 @@ class cloneExperiment_result: thrift_spec = ( (0, TType.STRING, 'success', None, None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'enf', (apache.airavata.api.error.ttypes.ExperimentNotFoundException, apache.airavata.api.error.ttypes.ExperimentNotFoundException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 3 - (4, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 4 - (5, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 5 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 ) - def __init__(self, success=None, ire=None, enf=None, ace=None, ase=None, ae=None,): + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): self.success = success self.ire = ire - self.enf = enf self.ace = ace self.ase = ase self.ae = ae @@ -24871,23 +25584,17 @@ class cloneExperiment_result: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRUCT: - self.enf = apache.airavata.api.error.ttypes.ExperimentNotFoundException() - self.enf.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: self.ace = apache.airavata.api.
<TRUNCATED>
