Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 5DA82200B26 for ; Mon, 27 Jun 2016 22:06:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 5C49A160A54; Mon, 27 Jun 2016 20:06:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id EDD58160A6E for ; Mon, 27 Jun 2016 22:06:47 +0200 (CEST) Received: (qmail 90466 invoked by uid 500); 27 Jun 2016 20:06:47 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 90308 invoked by uid 99); 27 Jun 2016 20:06:47 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 27 Jun 2016 20:06:47 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C3D75E00A7; Mon, 27 Jun 2016 20:06:46 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: scnakandala@apache.org To: commits@airavata.apache.org Date: Mon, 27 Jun 2016 20:06:49 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [04/17] airavata git commit: removing redundant experiment search API methods archived-at: Mon, 27 Jun 2016 20:06:50 -0000 http://git-wip-us.apache.org/repos/asf/airavata/blob/c9ddaeb3/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 8794b23..634301f 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 @@ -529,178 +529,6 @@ class Iface: """ pass - def searchExperimentsByName(self, authzToken, gatewayId, userName, expName, limit, offset): - """ - - Search User Experiments by Name - Search user Experiments using experiment name with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the user who created the experiments. - - @param expName - Experiment name to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - expName - - limit - - offset - """ - pass - - def searchExperimentsByDesc(self, authzToken, gatewayId, userName, description, limit, offset): - """ - - Search By Experiment Description - Search Experiments by experiment description with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param description - Experiment description to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - description - - limit - - offset - """ - pass - - def searchExperimentsByApplication(self, authzToken, gatewayId, userName, applicationId, limit, offset): - """ - - Search Experiment By the Application - Search Experiments of a particular application id with pagination. Results will be sorted based on creation time DESC - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param applicationId - Application id to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - applicationId - - limit - - offset - """ - pass - - def searchExperimentsByStatus(self, authzToken, gatewayId, userName, experimentState, limit, offset): - """ - - Search User Experiments by Status - Search all the Experiments of the given user by experiment status with pagination. Results will be sorted based on creation time DESC - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the user making the request. - - @param experimentState - Experiement state to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - experimentState - - limit - - offset - """ - pass - - def searchExperimentsByCreationTime(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset): - """ - - Search User Experiments by the Creation Time - This will search all the experiments of the given user by experiment creation time with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param fromTime - Start time of the experiments creation time. - - @param toTime - End time of the experiement creation time. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - @return ExperimentSummaryModel - List of experiments for the given search filter. Here only the Experiment summary will be returned. - - - - Parameters: - - authzToken - - gatewayId - - userName - - fromTime - - toTime - - limit - - offset - """ - pass - def searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset): """ Search Experiments. @@ -4503,364 +4331,6 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result") - def searchExperimentsByName(self, authzToken, gatewayId, userName, expName, limit, offset): - """ - - Search User Experiments by Name - Search user Experiments using experiment name with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the user who created the experiments. - - @param expName - Experiment name to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - expName - - limit - - offset - """ - self.send_searchExperimentsByName(authzToken, gatewayId, userName, expName, limit, offset) - return self.recv_searchExperimentsByName() - - def send_searchExperimentsByName(self, authzToken, gatewayId, userName, expName, limit, offset): - self._oprot.writeMessageBegin('searchExperimentsByName', TMessageType.CALL, self._seqid) - args = searchExperimentsByName_args() - args.authzToken = authzToken - args.gatewayId = gatewayId - args.userName = userName - args.expName = expName - args.limit = limit - args.offset = offset - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_searchExperimentsByName(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = searchExperimentsByName_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, "searchExperimentsByName failed: unknown result") - - def searchExperimentsByDesc(self, authzToken, gatewayId, userName, description, limit, offset): - """ - - Search By Experiment Description - Search Experiments by experiment description with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param description - Experiment description to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - description - - limit - - offset - """ - self.send_searchExperimentsByDesc(authzToken, gatewayId, userName, description, limit, offset) - return self.recv_searchExperimentsByDesc() - - def send_searchExperimentsByDesc(self, authzToken, gatewayId, userName, description, limit, offset): - self._oprot.writeMessageBegin('searchExperimentsByDesc', TMessageType.CALL, self._seqid) - args = searchExperimentsByDesc_args() - args.authzToken = authzToken - args.gatewayId = gatewayId - args.userName = userName - args.description = description - args.limit = limit - args.offset = offset - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_searchExperimentsByDesc(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = searchExperimentsByDesc_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, "searchExperimentsByDesc failed: unknown result") - - def searchExperimentsByApplication(self, authzToken, gatewayId, userName, applicationId, limit, offset): - """ - - Search Experiment By the Application - Search Experiments of a particular application id with pagination. Results will be sorted based on creation time DESC - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param applicationId - Application id to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - applicationId - - limit - - offset - """ - self.send_searchExperimentsByApplication(authzToken, gatewayId, userName, applicationId, limit, offset) - return self.recv_searchExperimentsByApplication() - - def send_searchExperimentsByApplication(self, authzToken, gatewayId, userName, applicationId, limit, offset): - self._oprot.writeMessageBegin('searchExperimentsByApplication', TMessageType.CALL, self._seqid) - args = searchExperimentsByApplication_args() - args.authzToken = authzToken - args.gatewayId = gatewayId - args.userName = userName - args.applicationId = applicationId - args.limit = limit - args.offset = offset - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_searchExperimentsByApplication(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = searchExperimentsByApplication_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, "searchExperimentsByApplication failed: unknown result") - - def searchExperimentsByStatus(self, authzToken, gatewayId, userName, experimentState, limit, offset): - """ - - Search User Experiments by Status - Search all the Experiments of the given user by experiment status with pagination. Results will be sorted based on creation time DESC - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the user making the request. - - @param experimentState - Experiement state to be matched. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - - - Parameters: - - authzToken - - gatewayId - - userName - - experimentState - - limit - - offset - """ - self.send_searchExperimentsByStatus(authzToken, gatewayId, userName, experimentState, limit, offset) - return self.recv_searchExperimentsByStatus() - - def send_searchExperimentsByStatus(self, authzToken, gatewayId, userName, experimentState, limit, offset): - self._oprot.writeMessageBegin('searchExperimentsByStatus', TMessageType.CALL, self._seqid) - args = searchExperimentsByStatus_args() - args.authzToken = authzToken - args.gatewayId = gatewayId - args.userName = userName - args.experimentState = experimentState - args.limit = limit - args.offset = offset - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_searchExperimentsByStatus(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = searchExperimentsByStatus_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, "searchExperimentsByStatus failed: unknown result") - - def searchExperimentsByCreationTime(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset): - """ - - Search User Experiments by the Creation Time - This will search all the experiments of the given user by experiment creation time with pagination. Results will be sorted based on creation time DESC. - - @param gatewayId - Unique identifier of the requested gateway. - - @param userName - Username of the requested user. - - @param fromTime - Start time of the experiments creation time. - - @param toTime - End time of the experiement creation time. - - @param limit - Amount of results to be fetched. - - @param offset - The starting point of the results to be fetched. - - @return ExperimentSummaryModel - List of experiments for the given search filter. Here only the Experiment summary will be returned. - - - - Parameters: - - authzToken - - gatewayId - - userName - - fromTime - - toTime - - limit - - offset - """ - self.send_searchExperimentsByCreationTime(authzToken, gatewayId, userName, fromTime, toTime, limit, offset) - return self.recv_searchExperimentsByCreationTime() - - def send_searchExperimentsByCreationTime(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset): - self._oprot.writeMessageBegin('searchExperimentsByCreationTime', TMessageType.CALL, self._seqid) - args = searchExperimentsByCreationTime_args() - args.authzToken = authzToken - args.gatewayId = gatewayId - args.userName = userName - args.fromTime = fromTime - args.toTime = toTime - args.limit = limit - args.offset = offset - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_searchExperimentsByCreationTime(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = searchExperimentsByCreationTime_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, "searchExperimentsByCreationTime failed: unknown result") - def searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset): """ Search Experiments. @@ -11082,11 +10552,6 @@ class Processor(Iface, TProcessor): self._processMap["getUserProjects"] = Processor.process_getUserProjects self._processMap["searchProjectsByProjectName"] = Processor.process_searchProjectsByProjectName self._processMap["searchProjectsByProjectDesc"] = Processor.process_searchProjectsByProjectDesc - self._processMap["searchExperimentsByName"] = Processor.process_searchExperimentsByName - self._processMap["searchExperimentsByDesc"] = Processor.process_searchExperimentsByDesc - self._processMap["searchExperimentsByApplication"] = Processor.process_searchExperimentsByApplication - self._processMap["searchExperimentsByStatus"] = Processor.process_searchExperimentsByStatus - self._processMap["searchExperimentsByCreationTime"] = Processor.process_searchExperimentsByCreationTime self._processMap["searchExperiments"] = Processor.process_searchExperiments self._processMap["getExperimentStatistics"] = Processor.process_getExperimentStatistics self._processMap["getExperimentsInProject"] = Processor.process_getExperimentsInProject @@ -12073,161 +11538,6 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_searchExperimentsByName(self, seqid, iprot, oprot): - args = searchExperimentsByName_args() - args.read(iprot) - iprot.readMessageEnd() - result = searchExperimentsByName_result() - try: - result.success = self._handler.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset) - 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("searchExperimentsByName", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_searchExperimentsByDesc(self, seqid, iprot, oprot): - args = searchExperimentsByDesc_args() - args.read(iprot) - iprot.readMessageEnd() - result = searchExperimentsByDesc_result() - try: - result.success = self._handler.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset) - 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("searchExperimentsByDesc", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_searchExperimentsByApplication(self, seqid, iprot, oprot): - args = searchExperimentsByApplication_args() - args.read(iprot) - iprot.readMessageEnd() - result = searchExperimentsByApplication_result() - try: - result.success = self._handler.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset) - 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("searchExperimentsByApplication", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_searchExperimentsByStatus(self, seqid, iprot, oprot): - args = searchExperimentsByStatus_args() - args.read(iprot) - iprot.readMessageEnd() - result = searchExperimentsByStatus_result() - try: - result.success = self._handler.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset) - 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("searchExperimentsByStatus", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_searchExperimentsByCreationTime(self, seqid, iprot, oprot): - args = searchExperimentsByCreationTime_args() - args.read(iprot) - iprot.readMessageEnd() - result = searchExperimentsByCreationTime_result() - try: - result.success = self._handler.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset) - 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("searchExperimentsByCreationTime", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - def process_searchExperiments(self, seqid, iprot, oprot): args = searchExperiments_args() args.read(iprot) @@ -20944,1086 +20254,11 @@ class deleteProject_result: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRUCT: - self.pnfe = apache.airavata.api.error.ttypes.ProjectNotFoundException() - self.pnfe.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('deleteProject_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.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.pnfe is not None: - oprot.writeFieldBegin('pnfe', TType.STRUCT, 4) - self.pnfe.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.success) - value = (value * 31) ^ hash(self.ire) - value = (value * 31) ^ hash(self.ace) - value = (value * 31) ^ hash(self.ase) - value = (value * 31) ^ hash(self.pnfe) - 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 getUserProjects_args: - """ - Attributes: - - authzToken - - gatewayId - - userName - - limit - - offset - """ - - 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, 'gatewayId', None, None, ), # 2 - (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.I32, 'limit', None, None, ), # 4 - (5, TType.I32, 'offset', None, None, ), # 5 - ) - - def __init__(self, authzToken=None, gatewayId=None, userName=None, limit=None, offset=None,): - self.authzToken = authzToken - self.gatewayId = gatewayId - self.userName = userName - self.limit = limit - self.offset = offset - - 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.gatewayId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.userName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.I32: - self.limit = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I32: - self.offset = iprot.readI32() - 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('getUserProjects_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) - oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 2) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() - if self.userName is not None: - oprot.writeFieldBegin('userName', TType.STRING, 3) - oprot.writeString(self.userName) - oprot.writeFieldEnd() - if self.limit is not None: - oprot.writeFieldBegin('limit', TType.I32, 4) - oprot.writeI32(self.limit) - oprot.writeFieldEnd() - if self.offset is not None: - oprot.writeFieldBegin('offset', TType.I32, 5) - oprot.writeI32(self.offset) - 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.gatewayId is None: - raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') - if self.userName is None: - raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.limit is None: - raise TProtocol.TProtocolException(message='Required field limit is unset!') - if self.offset is None: - raise TProtocol.TProtocolException(message='Required field offset is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.limit) - value = (value * 31) ^ hash(self.offset) - 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 getUserProjects_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Project, apache.airavata.model.workspace.ttypes.Project.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, '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, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - 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 == 0: - if ftype == TType.LIST: - self.success = [] - (_etype42, _size39) = iprot.readListBegin() - for _i43 in xrange(_size39): - _elem44 = apache.airavata.model.workspace.ttypes.Project() - _elem44.read(iprot) - self.success.append(_elem44) - 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) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - 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('getUserProjects_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter45 in self.success: - iter45.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.success) - value = (value * 31) ^ hash(self.ire) - 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 searchProjectsByProjectName_args: - """ - Attributes: - - authzToken - - gatewayId - - userName - - projectName - - limit - - offset - """ - - 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, 'gatewayId', None, None, ), # 2 - (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.STRING, 'projectName', None, None, ), # 4 - (5, TType.I32, 'limit', None, None, ), # 5 - (6, TType.I32, 'offset', None, None, ), # 6 - ) - - def __init__(self, authzToken=None, gatewayId=None, userName=None, projectName=None, limit=None, offset=None,): - self.authzToken = authzToken - self.gatewayId = gatewayId - self.userName = userName - self.projectName = projectName - self.limit = limit - self.offset = offset - - 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.gatewayId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.userName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.projectName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I32: - self.limit = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I32: - self.offset = iprot.readI32() - 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('searchProjectsByProjectName_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) - oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 2) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() - if self.userName is not None: - oprot.writeFieldBegin('userName', TType.STRING, 3) - oprot.writeString(self.userName) - oprot.writeFieldEnd() - if self.projectName is not None: - oprot.writeFieldBegin('projectName', TType.STRING, 4) - oprot.writeString(self.projectName) - oprot.writeFieldEnd() - if self.limit is not None: - oprot.writeFieldBegin('limit', TType.I32, 5) - oprot.writeI32(self.limit) - oprot.writeFieldEnd() - if self.offset is not None: - oprot.writeFieldBegin('offset', TType.I32, 6) - oprot.writeI32(self.offset) - 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.gatewayId is None: - raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') - if self.userName is None: - raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.projectName is None: - raise TProtocol.TProtocolException(message='Required field projectName is unset!') - if self.limit is None: - raise TProtocol.TProtocolException(message='Required field limit is unset!') - if self.offset is None: - raise TProtocol.TProtocolException(message='Required field offset is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.projectName) - value = (value * 31) ^ hash(self.limit) - value = (value * 31) ^ hash(self.offset) - 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 searchProjectsByProjectName_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Project, apache.airavata.model.workspace.ttypes.Project.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, '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, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - 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 == 0: - if ftype == TType.LIST: - self.success = [] - (_etype49, _size46) = iprot.readListBegin() - for _i50 in xrange(_size46): - _elem51 = apache.airavata.model.workspace.ttypes.Project() - _elem51.read(iprot) - self.success.append(_elem51) - 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) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - 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('searchProjectsByProjectName_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter52 in self.success: - iter52.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.success) - value = (value * 31) ^ hash(self.ire) - 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 searchProjectsByProjectDesc_args: - """ - Attributes: - - authzToken - - gatewayId - - userName - - description - - limit - - offset - """ - - 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, 'gatewayId', None, None, ), # 2 - (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.STRING, 'description', None, None, ), # 4 - (5, TType.I32, 'limit', None, None, ), # 5 - (6, TType.I32, 'offset', None, None, ), # 6 - ) - - def __init__(self, authzToken=None, gatewayId=None, userName=None, description=None, limit=None, offset=None,): - self.authzToken = authzToken - self.gatewayId = gatewayId - self.userName = userName - self.description = description - self.limit = limit - self.offset = offset - - 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.gatewayId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.userName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.description = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I32: - self.limit = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I32: - self.offset = iprot.readI32() - 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('searchProjectsByProjectDesc_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) - oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 2) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() - if self.userName is not None: - oprot.writeFieldBegin('userName', TType.STRING, 3) - oprot.writeString(self.userName) - oprot.writeFieldEnd() - if self.description is not None: - oprot.writeFieldBegin('description', TType.STRING, 4) - oprot.writeString(self.description) - oprot.writeFieldEnd() - if self.limit is not None: - oprot.writeFieldBegin('limit', TType.I32, 5) - oprot.writeI32(self.limit) - oprot.writeFieldEnd() - if self.offset is not None: - oprot.writeFieldBegin('offset', TType.I32, 6) - oprot.writeI32(self.offset) - 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.gatewayId is None: - raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') - if self.userName is None: - raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.description is None: - raise TProtocol.TProtocolException(message='Required field description is unset!') - if self.limit is None: - raise TProtocol.TProtocolException(message='Required field limit is unset!') - if self.offset is None: - raise TProtocol.TProtocolException(message='Required field offset is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.description) - value = (value * 31) ^ hash(self.limit) - value = (value * 31) ^ hash(self.offset) - 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 searchProjectsByProjectDesc_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Project, apache.airavata.model.workspace.ttypes.Project.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, '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, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - 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 == 0: - if ftype == TType.LIST: - self.success = [] - (_etype56, _size53) = iprot.readListBegin() - for _i57 in xrange(_size53): - _elem58 = apache.airavata.model.workspace.ttypes.Project() - _elem58.read(iprot) - self.success.append(_elem58) - 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) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - 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('searchProjectsByProjectDesc_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter59 in self.success: - iter59.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.success) - value = (value * 31) ^ hash(self.ire) - 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 searchExperimentsByName_args: - """ - Attributes: - - authzToken - - gatewayId - - userName - - expName - - limit - - offset - """ - - 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, 'gatewayId', None, None, ), # 2 - (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.STRING, 'expName', None, None, ), # 4 - (5, TType.I32, 'limit', None, None, ), # 5 - (6, TType.I32, 'offset', None, None, ), # 6 - ) - - def __init__(self, authzToken=None, gatewayId=None, userName=None, expName=None, limit=None, offset=None,): - self.authzToken = authzToken - self.gatewayId = gatewayId - self.userName = userName - self.expName = expName - self.limit = limit - self.offset = offset - - 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.gatewayId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.userName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.expName = iprot.readString() + self.pnfe = apache.airavata.api.error.ttypes.ProjectNotFoundException() + self.pnfe.read(iprot) else: iprot.skip(ftype) elif fid == 5: - if ftype == TType.I32: - self.limit = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I32: - self.offset = iprot.readI32() - 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('searchExperimentsByName_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) - oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 2) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() - if self.userName is not None: - oprot.writeFieldBegin('userName', TType.STRING, 3) - oprot.writeString(self.userName) - oprot.writeFieldEnd() - if self.expName is not None: - oprot.writeFieldBegin('expName', TType.STRING, 4) - oprot.writeString(self.expName) - oprot.writeFieldEnd() - if self.limit is not None: - oprot.writeFieldBegin('limit', TType.I32, 5) - oprot.writeI32(self.limit) - oprot.writeFieldEnd() - if self.offset is not None: - oprot.writeFieldBegin('offset', TType.I32, 6) - oprot.writeI32(self.offset) - 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.gatewayId is None: - raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') - if self.userName is None: - raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.expName is None: - raise TProtocol.TProtocolException(message='Required field expName is unset!') - if self.limit is None: - raise TProtocol.TProtocolException(message='Required field limit is unset!') - if self.offset is None: - raise TProtocol.TProtocolException(message='Required field offset is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.expName) - value = (value * 31) ^ hash(self.limit) - value = (value * 31) ^ hash(self.offset) - 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 searchExperimentsByName_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.experiment.ttypes.ExperimentSummaryModel, apache.airavata.model.experiment.ttypes.ExperimentSummaryModel.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, '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, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - 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 == 0: - if ftype == TType.LIST: - self.success = [] - (_etype63, _size60) = iprot.readListBegin() - for _i64 in xrange(_size60): - _elem65 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem65.read(iprot) - self.success.append(_elem65) - 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) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: if ftype == TType.STRUCT: self.ae = apache.airavata.api.error.ttypes.AuthorizationException() self.ae.read(iprot) @@ -22038,13 +20273,10 @@ class searchExperimentsByName_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('searchExperimentsByName_result') + oprot.writeStructBegin('deleteProject_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter66 in self.success: - iter66.write(oprot) - oprot.writeListEnd() + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -22058,8 +20290,12 @@ class searchExperimentsByName_result: oprot.writeFieldBegin('ase', TType.STRUCT, 3) self.ase.write(oprot) oprot.writeFieldEnd() + if self.pnfe is not None: + oprot.writeFieldBegin('pnfe', TType.STRUCT, 4) + self.pnfe.write(oprot) + oprot.writeFieldEnd() if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) + oprot.writeFieldBegin('ae', TType.STRUCT, 5) self.ae.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22075,6 +20311,7 @@ class searchExperimentsByName_result: value = (value * 31) ^ hash(self.ire) value = (value * 31) ^ hash(self.ace) value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.pnfe) value = (value * 31) ^ hash(self.ae) return value @@ -22089,13 +20326,12 @@ class searchExperimentsByName_result: def __ne__(self, other): return not (self == other) -class searchExperimentsByDesc_args: +class getUserProjects_args: """ Attributes: - authzToken - gatewayId - userName - - description - limit - offset """ @@ -22105,16 +20341,14 @@ class searchExperimentsByDesc_args: (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.STRING, 'description', None, None, ), # 4 - (5, TType.I32, 'limit', None, None, ), # 5 - (6, TType.I32, 'offset', None, None, ), # 6 + (4, TType.I32, 'limit', None, None, ), # 4 + (5, TType.I32, 'offset', None, None, ), # 5 ) - def __init__(self, authzToken=None, gatewayId=None, userName=None, description=None, limit=None, offset=None,): + def __init__(self, authzToken=None, gatewayId=None, userName=None, limit=None, offset=None,): self.authzToken = authzToken self.gatewayId = gatewayId self.userName = userName - self.description = description self.limit = limit self.offset = offset @@ -22144,16 +20378,11 @@ class searchExperimentsByDesc_args: else: iprot.skip(ftype) elif fid == 4: - if ftype == TType.STRING: - self.description = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: if ftype == TType.I32: self.limit = iprot.readI32() else: iprot.skip(ftype) - elif fid == 6: + elif fid == 5: if ftype == TType.I32: self.offset = iprot.readI32() else: @@ -22167,7 +20396,7 @@ class searchExperimentsByDesc_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('searchExperimentsByDesc_args') + oprot.writeStructBegin('getUserProjects_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -22180,16 +20409,12 @@ class searchExperimentsByDesc_args: oprot.writeFieldBegin('userName', TType.STRING, 3) oprot.writeString(self.userName) oprot.writeFieldEnd() - if self.description is not None: - oprot.writeFieldBegin('description', TType.STRING, 4) - oprot.writeString(self.description) - oprot.writeFieldEnd() if self.limit is not None: - oprot.writeFieldBegin('limit', TType.I32, 5) + oprot.writeFieldBegin('limit', TType.I32, 4) oprot.writeI32(self.limit) oprot.writeFieldEnd() if self.offset is not None: - oprot.writeFieldBegin('offset', TType.I32, 6) + oprot.writeFieldBegin('offset', TType.I32, 5) oprot.writeI32(self.offset) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22202,8 +20427,6 @@ class searchExperimentsByDesc_args: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') if self.userName is None: raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.description is None: - raise TProtocol.TProtocolException(message='Required field description is unset!') if self.limit is None: raise TProtocol.TProtocolException(message='Required field limit is unset!') if self.offset is None: @@ -22216,7 +20439,6 @@ class searchExperimentsByDesc_args: value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.description) value = (value * 31) ^ hash(self.limit) value = (value * 31) ^ hash(self.offset) return value @@ -22232,7 +20454,7 @@ class searchExperimentsByDesc_args: def __ne__(self, other): return not (self == other) -class searchExperimentsByDesc_result: +class getUserProjects_result: """ Attributes: - success @@ -22243,7 +20465,7 @@ class searchExperimentsByDesc_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.experiment.ttypes.ExperimentSummaryModel, apache.airavata.model.experiment.ttypes.ExperimentSummaryModel.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Project, apache.airavata.model.workspace.ttypes.Project.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, '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 @@ -22269,11 +20491,11 @@ class searchExperimentsByDesc_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype70, _size67) = iprot.readListBegin() - for _i71 in xrange(_size67): - _elem72 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem72.read(iprot) - self.success.append(_elem72) + (_etype42, _size39) = iprot.readListBegin() + for _i43 in xrange(_size39): + _elem44 = apache.airavata.model.workspace.ttypes.Project() + _elem44.read(iprot) + self.success.append(_elem44) iprot.readListEnd() else: iprot.skip(ftype) @@ -22310,12 +20532,12 @@ class searchExperimentsByDesc_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('searchExperimentsByDesc_result') + oprot.writeStructBegin('getUserProjects_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter73 in self.success: - iter73.write(oprot) + for iter45 in self.success: + iter45.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22361,13 +20583,13 @@ class searchExperimentsByDesc_result: def __ne__(self, other): return not (self == other) -class searchExperimentsByApplication_args: +class searchProjectsByProjectName_args: """ Attributes: - authzToken - gatewayId - userName - - applicationId + - projectName - limit - offset """ @@ -22377,16 +20599,16 @@ class searchExperimentsByApplication_args: (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.STRING, 'applicationId', None, None, ), # 4 + (4, TType.STRING, 'projectName', None, None, ), # 4 (5, TType.I32, 'limit', None, None, ), # 5 (6, TType.I32, 'offset', None, None, ), # 6 ) - def __init__(self, authzToken=None, gatewayId=None, userName=None, applicationId=None, limit=None, offset=None,): + def __init__(self, authzToken=None, gatewayId=None, userName=None, projectName=None, limit=None, offset=None,): self.authzToken = authzToken self.gatewayId = gatewayId self.userName = userName - self.applicationId = applicationId + self.projectName = projectName self.limit = limit self.offset = offset @@ -22417,7 +20639,7 @@ class searchExperimentsByApplication_args: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.applicationId = iprot.readString() + self.projectName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: @@ -22439,7 +20661,7 @@ class searchExperimentsByApplication_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('searchExperimentsByApplication_args') + oprot.writeStructBegin('searchProjectsByProjectName_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -22452,9 +20674,9 @@ class searchExperimentsByApplication_args: oprot.writeFieldBegin('userName', TType.STRING, 3) oprot.writeString(self.userName) oprot.writeFieldEnd() - if self.applicationId is not None: - oprot.writeFieldBegin('applicationId', TType.STRING, 4) - oprot.writeString(self.applicationId) + if self.projectName is not None: + oprot.writeFieldBegin('projectName', TType.STRING, 4) + oprot.writeString(self.projectName) oprot.writeFieldEnd() if self.limit is not None: oprot.writeFieldBegin('limit', TType.I32, 5) @@ -22474,8 +20696,8 @@ class searchExperimentsByApplication_args: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') if self.userName is None: raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.applicationId is None: - raise TProtocol.TProtocolException(message='Required field applicationId is unset!') + if self.projectName is None: + raise TProtocol.TProtocolException(message='Required field projectName is unset!') if self.limit is None: raise TProtocol.TProtocolException(message='Required field limit is unset!') if self.offset is None: @@ -22488,7 +20710,7 @@ class searchExperimentsByApplication_args: value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.applicationId) + value = (value * 31) ^ hash(self.projectName) value = (value * 31) ^ hash(self.limit) value = (value * 31) ^ hash(self.offset) return value @@ -22504,7 +20726,7 @@ class searchExperimentsByApplication_args: def __ne__(self, other): return not (self == other) -class searchExperimentsByApplication_result: +class searchProjectsByProjectName_result: """ Attributes: - success @@ -22515,7 +20737,7 @@ class searchExperimentsByApplication_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.experiment.ttypes.ExperimentSummaryModel, apache.airavata.model.experiment.ttypes.ExperimentSummaryModel.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Project, apache.airavata.model.workspace.ttypes.Project.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, '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 @@ -22541,11 +20763,11 @@ class searchExperimentsByApplication_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype77, _size74) = iprot.readListBegin() - for _i78 in xrange(_size74): - _elem79 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem79.read(iprot) - self.success.append(_elem79) + (_etype49, _size46) = iprot.readListBegin() + for _i50 in xrange(_size46): + _elem51 = apache.airavata.model.workspace.ttypes.Project() + _elem51.read(iprot) + self.success.append(_elem51) iprot.readListEnd() else: iprot.skip(ftype) @@ -22582,12 +20804,12 @@ class searchExperimentsByApplication_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('searchExperimentsByApplication_result') + oprot.writeStructBegin('searchProjectsByProjectName_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter80 in self.success: - iter80.write(oprot) + for iter52 in self.success: + iter52.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22633,13 +20855,13 @@ class searchExperimentsByApplication_result: def __ne__(self, other): return not (self == other) -class searchExperimentsByStatus_args: +class searchProjectsByProjectDesc_args: """ Attributes: - authzToken - gatewayId - userName - - experimentState + - description - limit - offset """ @@ -22649,16 +20871,16 @@ class searchExperimentsByStatus_args: (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 (3, TType.STRING, 'userName', None, None, ), # 3 - (4, TType.I32, 'experimentState', None, None, ), # 4 + (4, TType.STRING, 'description', None, None, ), # 4 (5, TType.I32, 'limit', None, None, ), # 5 (6, TType.I32, 'offset', None, None, ), # 6 ) - def __init__(self, authzToken=None, gatewayId=None, userName=None, experimentState=None, limit=None, offset=None,): + def __init__(self, authzToken=None, gatewayId=None, userName=None, description=None, limit=None, offset=None,): self.authzToken = authzToken self.gatewayId = gatewayId self.userName = userName - self.experimentState = experimentState + self.description = description self.limit = limit self.offset = offset @@ -22688,8 +20910,8 @@ class searchExperimentsByStatus_args: else: iprot.skip(ftype) elif fid == 4: - if ftype == TType.I32: - self.experimentState = iprot.readI32() + if ftype == TType.STRING: + self.description = iprot.readString() else: iprot.skip(ftype) elif fid == 5: @@ -22711,7 +20933,7 @@ class searchExperimentsByStatus_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('searchExperimentsByStatus_args') + oprot.writeStructBegin('searchProjectsByProjectDesc_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -22724,9 +20946,9 @@ class searchExperimentsByStatus_args: oprot.writeFieldBegin('userName', TType.STRING, 3) oprot.writeString(self.userName) oprot.writeFieldEnd() - if self.experimentState is not None: - oprot.writeFieldBegin('experimentState', TType.I32, 4) - oprot.writeI32(self.experimentState) + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 4) + oprot.writeString(self.description) oprot.writeFieldEnd() if self.limit is not None: oprot.writeFieldBegin('limit', TType.I32, 5) @@ -22746,294 +20968,8 @@ class searchExperimentsByStatus_args: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') if self.userName is None: raise TProtocol.TProtocolException(message='Required field userName is unset!') - if self.experimentState is None: - raise TProtocol.TProtocolException(message='Required field experimentState is unset!') - if self.limit is None: - raise TProtocol.TProtocolException(message='Required field limit is unset!') - if self.offset is None: - raise TProtocol.TProtocolException(message='Required field offset is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.userName) - value = (value * 31) ^ hash(self.experimentState) - value = (value * 31) ^ hash(self.limit) - value = (value * 31) ^ hash(self.offset) - 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 searchExperimentsByStatus_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.experiment.ttypes.ExperimentSummaryModel, apache.airavata.model.experiment.ttypes.ExperimentSummaryModel.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, '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, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - 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 == 0: - if ftype == TType.LIST: - self.success = [] - (_etype84, _size81) = iprot.readListBegin() - for _i85 in xrange(_size81): - _elem86 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem86.read(iprot) - self.success.append(_elem86) - 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) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - 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('searchExperimentsByStatus_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter87 in self.success: - iter87.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() - o