http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php index 32140e2..cd5542a 100644 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php @@ -519,35 +519,23 @@ class DataReplicaLocationModel { /** * @var int */ - public $replicaLocationCategory = null; - /** - * @var int - */ - public $replicaPersistentType = null; - /** - * @var string - */ - public $storageResourceId = null; - /** - * @var string - */ - public $storageResourceHostName = null; + public $validUntilTime = null; /** * @var int */ - public $dataMovementProtocol = null; + public $replicaLocationCategory = null; /** * @var int */ - public $hostPort = null; + public $replicaPersistentType = null; /** * @var string */ - public $filePath = null; + public $storageResourceId = null; /** * @var string */ - public $replicaUrl = null; + public $fileAbsolutePath = null; /** * @var array */ @@ -581,38 +569,26 @@ class DataReplicaLocationModel { 'type' => TType::I64, ), 7 => array( - 'var' => 'replicaLocationCategory', - 'type' => TType::I32, + 'var' => 'validUntilTime', + 'type' => TType::I64, ), 8 => array( - 'var' => 'replicaPersistentType', + 'var' => 'replicaLocationCategory', 'type' => TType::I32, ), 9 => array( - 'var' => 'storageResourceId', - 'type' => TType::STRING, + 'var' => 'replicaPersistentType', + 'type' => TType::I32, ), 10 => array( - 'var' => 'storageResourceHostName', + 'var' => 'storageResourceId', 'type' => TType::STRING, ), 11 => array( - 'var' => 'dataMovementProtocol', - 'type' => TType::I32, - ), - 12 => array( - 'var' => 'hostPort', - 'type' => TType::I64, - ), - 13 => array( - 'var' => 'filePath', - 'type' => TType::STRING, - ), - 14 => array( - 'var' => 'replicaUrl', + 'var' => 'fileAbsolutePath', 'type' => TType::STRING, ), - 15 => array( + 12 => array( 'var' => 'replicaMetadata', 'type' => TType::MAP, 'ktype' => TType::STRING, @@ -645,6 +621,9 @@ class DataReplicaLocationModel { if (isset($vals['lastModifiedTime'])) { $this->lastModifiedTime = $vals['lastModifiedTime']; } + if (isset($vals['validUntilTime'])) { + $this->validUntilTime = $vals['validUntilTime']; + } if (isset($vals['replicaLocationCategory'])) { $this->replicaLocationCategory = $vals['replicaLocationCategory']; } @@ -654,20 +633,8 @@ class DataReplicaLocationModel { if (isset($vals['storageResourceId'])) { $this->storageResourceId = $vals['storageResourceId']; } - if (isset($vals['storageResourceHostName'])) { - $this->storageResourceHostName = $vals['storageResourceHostName']; - } - if (isset($vals['dataMovementProtocol'])) { - $this->dataMovementProtocol = $vals['dataMovementProtocol']; - } - if (isset($vals['hostPort'])) { - $this->hostPort = $vals['hostPort']; - } - if (isset($vals['filePath'])) { - $this->filePath = $vals['filePath']; - } - if (isset($vals['replicaUrl'])) { - $this->replicaUrl = $vals['replicaUrl']; + if (isset($vals['fileAbsolutePath'])) { + $this->fileAbsolutePath = $vals['fileAbsolutePath']; } if (isset($vals['replicaMetadata'])) { $this->replicaMetadata = $vals['replicaMetadata']; @@ -737,62 +704,41 @@ class DataReplicaLocationModel { } break; case 7: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->replicaLocationCategory); + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->validUntilTime); } else { $xfer += $input->skip($ftype); } break; case 8: if ($ftype == TType::I32) { - $xfer += $input->readI32($this->replicaPersistentType); + $xfer += $input->readI32($this->replicaLocationCategory); } else { $xfer += $input->skip($ftype); } break; case 9: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageResourceId); + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaPersistentType); } else { $xfer += $input->skip($ftype); } break; case 10: if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageResourceHostName); + $xfer += $input->readString($this->storageResourceId); } else { $xfer += $input->skip($ftype); } break; case 11: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->dataMovementProtocol); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->hostPort); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->filePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 14: if ($ftype == TType::STRING) { - $xfer += $input->readString($this->replicaUrl); + $xfer += $input->readString($this->fileAbsolutePath); } else { $xfer += $input->skip($ftype); } break; - case 15: + case 12: if ($ftype == TType::MAP) { $this->replicaMetadata = array(); $_size23 = 0; @@ -855,51 +801,36 @@ class DataReplicaLocationModel { $xfer += $output->writeI64($this->lastModifiedTime); $xfer += $output->writeFieldEnd(); } + if ($this->validUntilTime !== null) { + $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 7); + $xfer += $output->writeI64($this->validUntilTime); + $xfer += $output->writeFieldEnd(); + } if ($this->replicaLocationCategory !== null) { - $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 7); + $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 8); $xfer += $output->writeI32($this->replicaLocationCategory); $xfer += $output->writeFieldEnd(); } if ($this->replicaPersistentType !== null) { - $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 8); + $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 9); $xfer += $output->writeI32($this->replicaPersistentType); $xfer += $output->writeFieldEnd(); } if ($this->storageResourceId !== null) { - $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 9); + $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 10); $xfer += $output->writeString($this->storageResourceId); $xfer += $output->writeFieldEnd(); } - if ($this->storageResourceHostName !== null) { - $xfer += $output->writeFieldBegin('storageResourceHostName', TType::STRING, 10); - $xfer += $output->writeString($this->storageResourceHostName); - $xfer += $output->writeFieldEnd(); - } - if ($this->dataMovementProtocol !== null) { - $xfer += $output->writeFieldBegin('dataMovementProtocol', TType::I32, 11); - $xfer += $output->writeI32($this->dataMovementProtocol); - $xfer += $output->writeFieldEnd(); - } - if ($this->hostPort !== null) { - $xfer += $output->writeFieldBegin('hostPort', TType::I64, 12); - $xfer += $output->writeI64($this->hostPort); - $xfer += $output->writeFieldEnd(); - } - if ($this->filePath !== null) { - $xfer += $output->writeFieldBegin('filePath', TType::STRING, 13); - $xfer += $output->writeString($this->filePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaUrl !== null) { - $xfer += $output->writeFieldBegin('replicaUrl', TType::STRING, 14); - $xfer += $output->writeString($this->replicaUrl); + if ($this->fileAbsolutePath !== null) { + $xfer += $output->writeFieldBegin('fileAbsolutePath', TType::STRING, 11); + $xfer += $output->writeString($this->fileAbsolutePath); $xfer += $output->writeFieldEnd(); } if ($this->replicaMetadata !== null) { if (!is_array($this->replicaMetadata)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('replicaMetadata', TType::MAP, 15); + $xfer += $output->writeFieldBegin('replicaMetadata', TType::MAP, 12); { $output->writeMapBegin(TType::STRING, TType::STRING, count($this->replicaMetadata)); {
http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/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 775a246..1ff70ac 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 @@ -57,6 +57,8 @@ class Iface: @return gateway Modified gateway obejct. + @exception AiravataClientException + Parameters: @@ -114,6 +116,19 @@ class Iface: def isGatewayExist(self, authzToken, gatewayId): """ + Check for the Existance of a Gateway within Airavata + + @param gatewayId + Provide the gatewayId of the gateway you want to check the existancy + + @return boolean + Boolean idetifier for the existance or non-existane of the gatewayId + + @return gatewayId + return the gatewayId of the existing gateway. + + + Parameters: - authzToken - gatewayId @@ -207,6 +222,16 @@ class Iface: def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ + Delete a Gateway + + @param gatewayId + The gateway Id of the Gateway to be deleted. + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - airavataCredStoreToken @@ -226,6 +251,7 @@ class Iface: The Project Object described in the workspace_model + Parameters: - authzToken - gatewayId @@ -235,7 +261,14 @@ class Iface: def updateProject(self, authzToken, projectId, updatedProject): """ - Update a Project + Update an Existing Project + + @param projectId + The projectId of the project needed an update. + + @return void + Currently this does not return any value. + Parameters: @@ -248,6 +281,14 @@ class Iface: def getProject(self, authzToken, projectId): """ Get a Project by ID + This method is to obtain a project by providing a projectId + + @param projectId + projectId of the project you require + + @return project + project data model will be returned + Parameters: @@ -258,6 +299,17 @@ class Iface: def deleteProject(self, authzToken, projectId): """ + Delete a Project + This method is used to delete an existing Project + + @param projectId + projectId of the project you want to delete + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - projectId @@ -266,18 +318,22 @@ class Iface: def getUserProjects(self, authzToken, gatewayId, userName, limit, offset): """ - * Get all Project by user with pagination. Results will be ordered based - * on creation time DESC - * - * @param gatewayId - * The identifier for the requested gateway. - * @param userName - * The identifier of the user - * @param limit - * The amount results to be fetched - * @param offset - * The starting point of the results to be fetched - * + Get all Project by user with pagination. Results will be ordered based + on creation time DESC + + @param gatewayId + The identifier for the requested gateway. + + @param userName + The identifier of the user + + @param limit + The amount results to be fetched + + @param offset + The starting point of the results to be fetched + + Parameters: - authzToken @@ -304,6 +360,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -330,6 +387,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -356,6 +414,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -382,6 +441,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -408,6 +468,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -434,6 +495,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -462,6 +524,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -489,6 +552,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -530,6 +594,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - projectId @@ -552,6 +617,7 @@ class Iface: @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -563,39 +629,40 @@ class Iface: def createExperiment(self, authzToken, gatewayId, experiment): """ - Create an experiment for the specified user belonging to the gateway. The gateway identity is not explicitly passed - but inferred from the sshKeyAuthentication header. This experiment is just a persistent place holder. The client - has to subsequently configure and launch the created experiment. No action is taken on Airavata Server except - registering the experiment in a persistent store. - - @param basicExperimentMetadata - The create experiment will require the basic experiment metadata like the name and description, intended user, - the gateway identifer and if the experiment should be shared public by defualt. During the creation of an experiment - the ExperimentMetadata is a required field. - - @return - The server-side generated.airavata.registry.core.experiment.globally unique identifier. - - @throws org.apache.airavata.model.error.InvalidRequestException - For any incorrect forming of the request itself. - - @throws org.apache.airavata.model.error.AiravataClientException - The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: - - UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative - step, then Airavata Registry will not have a provenance area setup. The client has to follow - gateway registration steps and retry this request. - - AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. - For now this is a place holder. - - INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake - is implemented, the authorization will be more substantial. - - @throws org.apache.airavata.model.error.AiravataSystemException - This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client - rather an Airavata Administrator will be notified to take corrective action. - + * Create an experiment for the specified user belonging to the gateway. The gateway identity is not explicitly passed + * but inferred from the sshKeyAuthentication header. This experiment is just a persistent place holder. The client + * has to subsequently configure and launch the created experiment. No action is taken on Airavata Server except + * registering the experiment in a persistent store. + * + * @param basicExperimentMetadata + * The create experiment will require the basic experiment metadata like the name and description, intended user, + * the gateway identifer and if the experiment should be shared public by defualt. During the creation of an experiment + * the ExperimentMetadata is a required field. + * + * @return + * The server-side generated.airavata.registry.core.experiment.globally unique identifier. + * + * @throws org.apache.airavata.model.error.InvalidRequestException + * For any incorrect forming of the request itself. + * + * @throws org.apache.airavata.model.error.AiravataClientException + * The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: + * + * UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative + * step, then Airavata Registry will not have a provenance area setup. The client has to follow + * gateway registration steps and retry this request. + * + * AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. + * For now this is a place holder. + * + * INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake + * is implemented, the authorization will be more substantial. + * + * @throws org.apache.airavata.model.error.AiravataSystemException + * This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client + * rather an Airavata Administrator will be notified to take corrective action. + * + * Parameters: - authzToken @@ -606,12 +673,18 @@ class Iface: def deleteExperiment(self, authzToken, experimentId): """ + Delete an Experiment + If the experiment is not already launched experiment can be deleted. @param authzToken + @param experiementId + Experiment ID of the experimnet you want to delete. + + @return boolean + Identifier for the success or failure of the deletion operation - @return boolean identifier for the success or failure of the deletion operation Parameters: @@ -622,37 +695,38 @@ class Iface: def getExperiment(self, authzToken, airavataExperimentId): """ - Fetch previously created experiment metadata. - - @param airavataExperimentId - The identifier for the requested experiment. This is returned during the create experiment step. - - @return experimentMetada - This method will return the previously stored experiment metadata. - - @throws org.apache.airavata.model.error.InvalidRequestException - For any incorrect forming of the request itself. - - @throws org.apache.airavata.model.error.ExperimentNotFoundException - If the specified experiment is not previously created, then an Experiment Not Found Exception is thrown. - - @throws org.apache.airavata.model.error.AiravataClientException - The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: - - UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative - step, then Airavata Registry will not have a provenance area setup. The client has to follow - gateway registration steps and retry this request. - - AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. - For now this is a place holder. - - INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake - is implemented, the authorization will be more substantial. - - @throws org.apache.airavata.model.error.AiravataSystemException - This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client - rather an Airavata Administrator will be notified to take corrective action. - + * Fetch previously created experiment metadata. + * + * @param airavataExperimentId + * The identifier for the requested experiment. This is returned during the create experiment step. + * + * @return experimentMetada + * This method will return the previously stored experiment metadata. + * + * @throws org.apache.airavata.model.error.InvalidRequestException + * For any incorrect forming of the request itself. + * + * @throws org.apache.airavata.model.error.ExperimentNotFoundException + * If the specified experiment is not previously created, then an Experiment Not Found Exception is thrown. + * + * @throws org.apache.airavata.model.error.AiravataClientException + * The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: + * + * UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative + * step, then Airavata Registry will not have a provenance area setup. The client has to follow + * gateway registration steps and retry this request. + * + * AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. + * For now this is a place holder. + * + * INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake + * is implemented, the authorization will be more substantial. + * + * @throws org.apache.airavata.model.error.AiravataSystemException + * This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client + * rather an Airavata Administrator will be notified to take corrective action. + * + * Parameters: - authzToken @@ -771,8 +845,11 @@ class Iface: * * Validate experiment configuration. A true in general indicates, the experiment is ready to be launched. * - * @param experimentID - * @return sucess/failure + * @param experimentId + * + * + * @return boolean + * Identifier for the success or failure of the validation operation * * @@ -826,6 +903,20 @@ class Iface: def getExperimentStatus(self, authzToken, airavataExperimentId): """ + Get Experiment Status + + Obtain the status os an experiment by providing the Experiment Id + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you require the status + + @return ExperimentStatus + ExperimentStatus model with current status will be returned. + + + Parameters: - authzToken - airavataExperimentId @@ -834,6 +925,19 @@ class Iface: def getExperimentOutputs(self, authzToken, airavataExperimentId): """ + Get Experiment Outputs + This method to be used when need to obtain outputs of a certain Experiment + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the outputs + + @return list + List of experiment outputs will be returned. They will be returned as a list of OutputDataObjectType for the experiment + + + Parameters: - authzToken - airavataExperimentId @@ -842,6 +946,19 @@ class Iface: def getIntermediateOutputs(self, authzToken, airavataExperimentId): """ + Get Intermediate Experiment Outputs + This method to be used when need to obtain intermediate outputs of a certain Experiment + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the intermediate outputs + + @return list + List of intermediate experiment outputs will be returned. They will be returned as a list of OutputDataObjectType for the experiment + + + Parameters: - authzToken - airavataExperimentId @@ -850,6 +967,19 @@ class Iface: def getJobStatuses(self, authzToken, airavataExperimentId): """ + Get Job Status for an Experiment + This method to be used when need to get the job status of an Experiment. An experiment may have one or many jobs; there for one or many job statuses may turnup + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the intermediate outputs + + @return JobStatus + Job status (string) for all all the existing jobs for the experiment will be returned in the form of a map + + + Parameters: - authzToken - airavataExperimentId @@ -858,6 +988,19 @@ class Iface: def getJobDetails(self, authzToken, airavataExperimentId): """ + Get Job Details for all the jobs within an Experiment + This method to be used when need to get the job details for one or many jobs of an Experiment. + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need job details + + @return list of JobDetails + Job details + + + Parameters: - authzToken - airavataExperimentId @@ -1683,7 +1826,7 @@ class Iface: The SSHJobSubmission object to be updated. @return status - Returns a success/failure of the deletion. + Returns a success/failure of the update. Parameters: @@ -1704,7 +1847,7 @@ class Iface: The CloudJobSubmission object to be updated. @return status - Returns a success/failure of the deletion. + Returns a success/failure of the update. Parameters: @@ -1716,6 +1859,19 @@ class Iface: def updateUnicoreJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, unicoreJobSubmission): """ + Update the UNIOCRE Job Submission details + + @param jobSubmissionInterfaceId + The identifier of the JobSubmission Interface to be updated. + + @param UnicoreJobSubmission + The UnicoreJobSubmission object to be updated. + + @return status + Returns a success/failure of the update. + + + Parameters: - authzToken - jobSubmissionInterfaceId @@ -1728,9 +1884,12 @@ class Iface: Add a Local data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId + @param resourceId The identifier of the compute resource to which JobSubmission protocol to be added + @param DMType + DMType object to be added to the resource. + @param priorityOrder Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. @@ -1741,6 +1900,7 @@ class Iface: Returns the unique job submission id. + Parameters: - authzToken - resourceId @@ -1764,6 +1924,7 @@ class Iface: Returns a success/failure of the update. + Parameters: - authzToken - dataMovementInterfaceId @@ -1773,11 +1934,14 @@ class Iface: def getLocalDataMovement(self, authzToken, dataMovementId): """ - * This method returns local datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return LOCALDataMovement instance - * + This method returns local datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return LOCALDataMovement instance + + Parameters: - authzToken @@ -1790,7 +1954,7 @@ class Iface: Add a SCP data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId + @param resourceId The identifier of the compute resource to which JobSubmission protocol to be added @param priorityOrder @@ -1836,11 +2000,14 @@ class Iface: def getSCPDataMovement(self, authzToken, dataMovementId): """ - * This method returns SCP datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return SCPDataMovement instance - * + This method returns SCP datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return SCPDataMovement instance + + Parameters: - authzToken @@ -1850,6 +2017,22 @@ class Iface: def addUnicoreDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, unicoreDataMovement): """ + Add a UNICORE data movement details to a compute resource + App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. + + @param resourceId + The identifier of the compute resource to which data movement protocol to be added + + @param priorityOrder + Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. + + @param UnicoreDataMovement + The UnicoreDataMovement object to be added to the resource. + + @return status + Returns the unique data movement id. + + Parameters: - authzToken - resourceId @@ -1861,6 +2044,20 @@ class Iface: def updateUnicoreDataMovementDetails(self, authzToken, dataMovementInterfaceId, unicoreDataMovement): """ + Update a selected UNICORE data movement details + App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. + + @param dataMovementInterfaceId + The identifier of the data movement Interface to be updated. + + @param UnicoreDataMovement + The UnicoreDataMovement object to be updated. + + @return status + Returns a success/failure of the update. + + + Parameters: - authzToken - dataMovementInterfaceId @@ -1870,6 +2067,15 @@ class Iface: def getUnicoreDataMovement(self, authzToken, dataMovementId): """ + This method returns UNICORE datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return UnicoreDataMovement instance + + + Parameters: - authzToken - dataMovementId @@ -1881,8 +2087,11 @@ class Iface: Add a GridFTP data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId - The identifier of the compute resource to which JobSubmission protocol to be added + @param resourceId + The identifier of the compute resource to which dataMovement protocol to be added + + @param DMType + The DMType object to be added to the resource. @param priorityOrder Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. @@ -1891,7 +2100,8 @@ class Iface: The GridFTPDataMovement object to be added to the resource. @return status - Returns the unique job submission id. + Returns the unique data movement id. + Parameters: @@ -1914,8 +2124,9 @@ class Iface: @param gridFTPDataMovement The GridFTPDataMovement object to be updated. - @return status - Returns a success/failure of the updation. + @return boolean + Returns a success/failure of the update. + Parameters: @@ -1927,11 +2138,14 @@ class Iface: def getGridFTPDataMovement(self, authzToken, dataMovementId): """ - * This method returns GridFTP datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return GridFTPDataMovement instance - * + This method returns GridFTP datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return GridFTPDataMovement instance + + Parameters: - authzToken @@ -1953,6 +2167,7 @@ class Iface: Returns a success/failure of the change. + Parameters: - authzToken - jobSubmissionInterfaceId @@ -1974,6 +2189,7 @@ class Iface: Returns a success/failure of the change. + Parameters: - authzToken - dataMovementInterfaceId @@ -2009,6 +2225,7 @@ class Iface: Returns a success/failure of the changes. + Parameters: - authzToken - dataMovementPriorityMap @@ -2026,6 +2243,7 @@ class Iface: Returns a success/failure of the deletion. + Parameters: - authzToken - computeResourceId @@ -2044,6 +2262,7 @@ class Iface: Returns a success/failure of the deletion. + Parameters: - authzToken - computeResourceId @@ -2086,6 +2305,19 @@ class Iface: def deleteBatchQueue(self, authzToken, computeResourceId, queueName): """ + Delete a Compute Resource Queue + + @param computeResourceId + The identifier of the compute resource which has the queue to be deleted + + @param queueName + Name of the queue need to be deleted. Name is the uniqueue identifier for the queue within a compute resource + + @return status + Returns a success/failure of the deletion. + + + Parameters: - authzToken - computeResourceId @@ -2537,6 +2769,8 @@ class Client(Iface): @return gateway Modified gateway obejct. + @exception AiravataClientException + Parameters: @@ -2724,6 +2958,19 @@ class Client(Iface): def isGatewayExist(self, authzToken, gatewayId): """ + Check for the Existance of a Gateway within Airavata + + @param gatewayId + Provide the gatewayId of the gateway you want to check the existancy + + @return boolean + Boolean idetifier for the existance or non-existane of the gatewayId + + @return gatewayId + return the gatewayId of the existing gateway. + + + Parameters: - authzToken - gatewayId @@ -2974,8 +3221,18 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result") - def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): - """ + def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): + """ + Delete a Gateway + + @param gatewayId + The gateway Id of the Gateway to be deleted. + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - airavataCredStoreToken @@ -3027,6 +3284,7 @@ class Client(Iface): The Project Object described in the workspace_model + Parameters: - authzToken - gatewayId @@ -3070,7 +3328,14 @@ class Client(Iface): def updateProject(self, authzToken, projectId, updatedProject): """ - Update a Project + Update an Existing Project + + @param projectId + The projectId of the project needed an update. + + @return void + Currently this does not return any value. + Parameters: @@ -3117,6 +3382,14 @@ class Client(Iface): def getProject(self, authzToken, projectId): """ Get a Project by ID + This method is to obtain a project by providing a projectId + + @param projectId + projectId of the project you require + + @return project + project data model will be returned + Parameters: @@ -3162,6 +3435,17 @@ class Client(Iface): def deleteProject(self, authzToken, projectId): """ + Delete a Project + This method is used to delete an existing Project + + @param projectId + projectId of the project you want to delete + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - projectId @@ -3205,18 +3489,22 @@ class Client(Iface): def getUserProjects(self, authzToken, gatewayId, userName, limit, offset): """ - * Get all Project by user with pagination. Results will be ordered based - * on creation time DESC - * - * @param gatewayId - * The identifier for the requested gateway. - * @param userName - * The identifier of the user - * @param limit - * The amount results to be fetched - * @param offset - * The starting point of the results to be fetched - * + Get all Project by user with pagination. Results will be ordered based + on creation time DESC + + @param gatewayId + The identifier for the requested gateway. + + @param userName + The identifier of the user + + @param limit + The amount results to be fetched + + @param offset + The starting point of the results to be fetched + + Parameters: - authzToken @@ -3279,6 +3567,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3342,6 +3631,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3405,6 +3695,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3468,6 +3759,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3531,6 +3823,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3594,6 +3887,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3659,6 +3953,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3724,6 +4019,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3837,6 +4133,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - projectId @@ -3896,6 +4193,7 @@ class Client(Iface): @param offset The starting point of the results to be fetched + Parameters: - authzToken - gatewayId @@ -3943,39 +4241,40 @@ class Client(Iface): def createExperiment(self, authzToken, gatewayId, experiment): """ - Create an experiment for the specified user belonging to the gateway. The gateway identity is not explicitly passed - but inferred from the sshKeyAuthentication header. This experiment is just a persistent place holder. The client - has to subsequently configure and launch the created experiment. No action is taken on Airavata Server except - registering the experiment in a persistent store. - - @param basicExperimentMetadata - The create experiment will require the basic experiment metadata like the name and description, intended user, - the gateway identifer and if the experiment should be shared public by defualt. During the creation of an experiment - the ExperimentMetadata is a required field. - - @return - The server-side generated.airavata.registry.core.experiment.globally unique identifier. - - @throws org.apache.airavata.model.error.InvalidRequestException - For any incorrect forming of the request itself. - - @throws org.apache.airavata.model.error.AiravataClientException - The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: - - UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative - step, then Airavata Registry will not have a provenance area setup. The client has to follow - gateway registration steps and retry this request. - - AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. - For now this is a place holder. - - INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake - is implemented, the authorization will be more substantial. - - @throws org.apache.airavata.model.error.AiravataSystemException - This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client - rather an Airavata Administrator will be notified to take corrective action. - + * Create an experiment for the specified user belonging to the gateway. The gateway identity is not explicitly passed + * but inferred from the sshKeyAuthentication header. This experiment is just a persistent place holder. The client + * has to subsequently configure and launch the created experiment. No action is taken on Airavata Server except + * registering the experiment in a persistent store. + * + * @param basicExperimentMetadata + * The create experiment will require the basic experiment metadata like the name and description, intended user, + * the gateway identifer and if the experiment should be shared public by defualt. During the creation of an experiment + * the ExperimentMetadata is a required field. + * + * @return + * The server-side generated.airavata.registry.core.experiment.globally unique identifier. + * + * @throws org.apache.airavata.model.error.InvalidRequestException + * For any incorrect forming of the request itself. + * + * @throws org.apache.airavata.model.error.AiravataClientException + * The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: + * + * UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative + * step, then Airavata Registry will not have a provenance area setup. The client has to follow + * gateway registration steps and retry this request. + * + * AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. + * For now this is a place holder. + * + * INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake + * is implemented, the authorization will be more substantial. + * + * @throws org.apache.airavata.model.error.AiravataSystemException + * This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client + * rather an Airavata Administrator will be notified to take corrective action. + * + * Parameters: - authzToken @@ -4020,12 +4319,18 @@ class Client(Iface): def deleteExperiment(self, authzToken, experimentId): """ + Delete an Experiment + If the experiment is not already launched experiment can be deleted. @param authzToken + @param experiementId + Experiment ID of the experimnet you want to delete. + + @return boolean + Identifier for the success or failure of the deletion operation - @return boolean identifier for the success or failure of the deletion operation Parameters: @@ -4069,37 +4374,38 @@ class Client(Iface): def getExperiment(self, authzToken, airavataExperimentId): """ - Fetch previously created experiment metadata. - - @param airavataExperimentId - The identifier for the requested experiment. This is returned during the create experiment step. - - @return experimentMetada - This method will return the previously stored experiment metadata. - - @throws org.apache.airavata.model.error.InvalidRequestException - For any incorrect forming of the request itself. - - @throws org.apache.airavata.model.error.ExperimentNotFoundException - If the specified experiment is not previously created, then an Experiment Not Found Exception is thrown. - - @throws org.apache.airavata.model.error.AiravataClientException - The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: - - UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative - step, then Airavata Registry will not have a provenance area setup. The client has to follow - gateway registration steps and retry this request. - - AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. - For now this is a place holder. - - INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake - is implemented, the authorization will be more substantial. - - @throws org.apache.airavata.model.error.AiravataSystemException - This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client - rather an Airavata Administrator will be notified to take corrective action. - + * Fetch previously created experiment metadata. + * + * @param airavataExperimentId + * The identifier for the requested experiment. This is returned during the create experiment step. + * + * @return experimentMetada + * This method will return the previously stored experiment metadata. + * + * @throws org.apache.airavata.model.error.InvalidRequestException + * For any incorrect forming of the request itself. + * + * @throws org.apache.airavata.model.error.ExperimentNotFoundException + * If the specified experiment is not previously created, then an Experiment Not Found Exception is thrown. + * + * @throws org.apache.airavata.model.error.AiravataClientException + * The following list of exceptions are thrown which Airavata Client can take corrective actions to resolve: + * + * UNKNOWN_GATEWAY_ID - If a Gateway is not registered with Airavata as a one time administrative + * step, then Airavata Registry will not have a provenance area setup. The client has to follow + * gateway registration steps and retry this request. + * + * AUTHENTICATION_FAILURE - How Authentication will be implemented is yet to be determined. + * For now this is a place holder. + * + * INVALID_AUTHORIZATION - This will throw an authorization exception. When a more robust security hand-shake + * is implemented, the authorization will be more substantial. + * + * @throws org.apache.airavata.model.error.AiravataSystemException + * This exception will be thrown for any Airavata Server side issues and if the problem cannot be corrected by the client + * rather an Airavata Administrator will be notified to take corrective action. + * + * Parameters: - authzToken @@ -4374,8 +4680,11 @@ class Client(Iface): * * Validate experiment configuration. A true in general indicates, the experiment is ready to be launched. * - * @param experimentID - * @return sucess/failure + * @param experimentId + * + * + * @return boolean + * Identifier for the success or failure of the validation operation * * @@ -4498,6 +4807,20 @@ class Client(Iface): def getExperimentStatus(self, authzToken, airavataExperimentId): """ + Get Experiment Status + + Obtain the status os an experiment by providing the Experiment Id + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you require the status + + @return ExperimentStatus + ExperimentStatus model with current status will be returned. + + + Parameters: - authzToken - airavataExperimentId @@ -4541,6 +4864,19 @@ class Client(Iface): def getExperimentOutputs(self, authzToken, airavataExperimentId): """ + Get Experiment Outputs + This method to be used when need to obtain outputs of a certain Experiment + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the outputs + + @return list + List of experiment outputs will be returned. They will be returned as a list of OutputDataObjectType for the experiment + + + Parameters: - authzToken - airavataExperimentId @@ -4584,6 +4920,19 @@ class Client(Iface): def getIntermediateOutputs(self, authzToken, airavataExperimentId): """ + Get Intermediate Experiment Outputs + This method to be used when need to obtain intermediate outputs of a certain Experiment + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the intermediate outputs + + @return list + List of intermediate experiment outputs will be returned. They will be returned as a list of OutputDataObjectType for the experiment + + + Parameters: - authzToken - airavataExperimentId @@ -4627,6 +4976,19 @@ class Client(Iface): def getJobStatuses(self, authzToken, airavataExperimentId): """ + Get Job Status for an Experiment + This method to be used when need to get the job status of an Experiment. An experiment may have one or many jobs; there for one or many job statuses may turnup + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need the intermediate outputs + + @return JobStatus + Job status (string) for all all the existing jobs for the experiment will be returned in the form of a map + + + Parameters: - authzToken - airavataExperimentId @@ -4670,6 +5032,19 @@ class Client(Iface): def getJobDetails(self, authzToken, airavataExperimentId): """ + Get Job Details for all the jobs within an Experiment + This method to be used when need to get the job details for one or many jobs of an Experiment. + + @param authzToken + + @param experiementId + Experiment ID of the experimnet you need job details + + @return list of JobDetails + Job details + + + Parameters: - authzToken - airavataExperimentId @@ -6937,7 +7312,7 @@ class Client(Iface): The SSHJobSubmission object to be updated. @return status - Returns a success/failure of the deletion. + Returns a success/failure of the update. Parameters: @@ -6992,7 +7367,7 @@ class Client(Iface): The CloudJobSubmission object to be updated. @return status - Returns a success/failure of the deletion. + Returns a success/failure of the update. Parameters: @@ -7038,6 +7413,19 @@ class Client(Iface): def updateUnicoreJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, unicoreJobSubmission): """ + Update the UNIOCRE Job Submission details + + @param jobSubmissionInterfaceId + The identifier of the JobSubmission Interface to be updated. + + @param UnicoreJobSubmission + The UnicoreJobSubmission object to be updated. + + @return status + Returns a success/failure of the update. + + + Parameters: - authzToken - jobSubmissionInterfaceId @@ -7084,9 +7472,12 @@ class Client(Iface): Add a Local data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId + @param resourceId The identifier of the compute resource to which JobSubmission protocol to be added + @param DMType + DMType object to be added to the resource. + @param priorityOrder Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. @@ -7097,6 +7488,7 @@ class Client(Iface): Returns the unique job submission id. + Parameters: - authzToken - resourceId @@ -7156,6 +7548,7 @@ class Client(Iface): Returns a success/failure of the update. + Parameters: - authzToken - dataMovementInterfaceId @@ -7199,11 +7592,14 @@ class Client(Iface): def getLocalDataMovement(self, authzToken, dataMovementId): """ - * This method returns local datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return LOCALDataMovement instance - * + This method returns local datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return LOCALDataMovement instance + + Parameters: - authzToken @@ -7249,7 +7645,7 @@ class Client(Iface): Add a SCP data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId + @param resourceId The identifier of the compute resource to which JobSubmission protocol to be added @param priorityOrder @@ -7365,11 +7761,14 @@ class Client(Iface): def getSCPDataMovement(self, authzToken, dataMovementId): """ - * This method returns SCP datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return SCPDataMovement instance - * + This method returns SCP datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return SCPDataMovement instance + + Parameters: - authzToken @@ -7412,6 +7811,22 @@ class Client(Iface): def addUnicoreDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, unicoreDataMovement): """ + Add a UNICORE data movement details to a compute resource + App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. + + @param resourceId + The identifier of the compute resource to which data movement protocol to be added + + @param priorityOrder + Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. + + @param UnicoreDataMovement + The UnicoreDataMovement object to be added to the resource. + + @return status + Returns the unique data movement id. + + Parameters: - authzToken - resourceId @@ -7459,6 +7874,20 @@ class Client(Iface): def updateUnicoreDataMovementDetails(self, authzToken, dataMovementInterfaceId, unicoreDataMovement): """ + Update a selected UNICORE data movement details + App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. + + @param dataMovementInterfaceId + The identifier of the data movement Interface to be updated. + + @param UnicoreDataMovement + The UnicoreDataMovement object to be updated. + + @return status + Returns a success/failure of the update. + + + Parameters: - authzToken - dataMovementInterfaceId @@ -7502,6 +7931,15 @@ class Client(Iface): def getUnicoreDataMovement(self, authzToken, dataMovementId): """ + This method returns UNICORE datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return UnicoreDataMovement instance + + + Parameters: - authzToken - dataMovementId @@ -7546,8 +7984,11 @@ class Client(Iface): Add a GridFTP data movement details to a compute resource App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. - @param computeResourceId - The identifier of the compute resource to which JobSubmission protocol to be added + @param resourceId + The identifier of the compute resource to which dataMovement protocol to be added + + @param DMType + The DMType object to be added to the resource. @param priorityOrder Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. @@ -7556,7 +7997,8 @@ class Client(Iface): The GridFTPDataMovement object to be added to the resource. @return status - Returns the unique job submission id. + Returns the unique data movement id. + Parameters: @@ -7615,8 +8057,9 @@ class Client(Iface): @param gridFTPDataMovement The GridFTPDataMovement object to be updated. - @return status - Returns a success/failure of the updation. + @return boolean + Returns a success/failure of the update. + Parameters: @@ -7662,11 +8105,14 @@ class Client(Iface): def getGridFTPDataMovement(self, authzToken, dataMovementId): """ - * This method returns GridFTP datamovement object - * @param dataMovementId - * The identifier of the datamovement Interface to be retrieved. - * @return GridFTPDataMovement instance - * + This method returns GridFTP datamovement object + + @param dataMovementId + The identifier of the datamovement Interface to be retrieved. + + @return GridFTPDataMovement instance + + Parameters: - authzToken @@ -7721,6 +8167,7 @@ class Client(Iface): Returns a success/failure of the change. + Parameters: - authzToken - jobSubmissionInterfaceId @@ -7776,6 +8223,7 @@ class Client(Iface): Returns a success/failure of the change. + Parameters: - authzToken - dataMovementInterfaceId @@ -7878,6 +8326,7 @@ class Client(Iface): Returns a success/failure of the changes. + Parameters: - authzToken - dataMovementPriorityMap @@ -7928,6 +8377,7 @@ class Client(Iface): Returns a success/failure of the deletion. + Parameters: - authzToken - computeResourceId @@ -7980,6 +8430,7 @@ class Client(Iface): Returns a success/failure of the deletion. + Parameters: - authzToken - computeResourceId @@ -8189,6 +8640,19 @@ class Client(Iface): def deleteBatchQueue(self, authzToken, computeResourceId, queueName): """ + Delete a Compute Resource Queue + + @param computeResourceId + The identifier of the compute resource which has the queue to be deleted + + @param queueName + Name of the queue need to be deleted. Name is the uniqueue identifier for the queue within a compute resource + + @return status + Returns a success/failure of the deletion. + + + Parameters: - authzToken - computeResourceId http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py index 26b6571..7c4a551 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py @@ -325,14 +325,11 @@ class DataReplicaLocationModel: - replicaDescription - creationTime - lastModifiedTime + - validUntilTime - replicaLocationCategory - replicaPersistentType - storageResourceId - - storageResourceHostName - - dataMovementProtocol - - hostPort - - filePath - - replicaUrl + - fileAbsolutePath - replicaMetadata """ @@ -344,32 +341,26 @@ class DataReplicaLocationModel: (4, TType.STRING, 'replicaDescription', None, None, ), # 4 (5, TType.I64, 'creationTime', None, None, ), # 5 (6, TType.I64, 'lastModifiedTime', None, None, ), # 6 - (7, TType.I32, 'replicaLocationCategory', None, None, ), # 7 - (8, TType.I32, 'replicaPersistentType', None, None, ), # 8 - (9, TType.STRING, 'storageResourceId', None, None, ), # 9 - (10, TType.STRING, 'storageResourceHostName', None, None, ), # 10 - (11, TType.I32, 'dataMovementProtocol', None, None, ), # 11 - (12, TType.I64, 'hostPort', None, None, ), # 12 - (13, TType.STRING, 'filePath', None, None, ), # 13 - (14, TType.STRING, 'replicaUrl', None, None, ), # 14 - (15, TType.MAP, 'replicaMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 15 + (7, TType.I64, 'validUntilTime', None, None, ), # 7 + (8, TType.I32, 'replicaLocationCategory', None, None, ), # 8 + (9, TType.I32, 'replicaPersistentType', None, None, ), # 9 + (10, TType.STRING, 'storageResourceId', None, None, ), # 10 + (11, TType.STRING, 'fileAbsolutePath', None, None, ), # 11 + (12, TType.MAP, 'replicaMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 12 ) - def __init__(self, replicaId=None, resourceId=None, replicaName=None, replicaDescription=None, creationTime=None, lastModifiedTime=None, replicaLocationCategory=None, replicaPersistentType=None, storageResourceId=None, storageResourceHostName=None, dataMovementProtocol=None, hostPort=None, filePath=None, replicaUrl=None, replicaMetadata=None,): + def __init__(self, replicaId=None, resourceId=None, replicaName=None, replicaDescription=None, creationTime=None, lastModifiedTime=None, validUntilTime=None, replicaLocationCategory=None, replicaPersistentType=None, storageResourceId=None, fileAbsolutePath=None, replicaMetadata=None,): self.replicaId = replicaId self.resourceId = resourceId self.replicaName = replicaName self.replicaDescription = replicaDescription self.creationTime = creationTime self.lastModifiedTime = lastModifiedTime + self.validUntilTime = validUntilTime self.replicaLocationCategory = replicaLocationCategory self.replicaPersistentType = replicaPersistentType self.storageResourceId = storageResourceId - self.storageResourceHostName = storageResourceHostName - self.dataMovementProtocol = dataMovementProtocol - self.hostPort = hostPort - self.filePath = filePath - self.replicaUrl = replicaUrl + self.fileAbsolutePath = fileAbsolutePath self.replicaMetadata = replicaMetadata def read(self, iprot): @@ -412,46 +403,31 @@ class DataReplicaLocationModel: else: iprot.skip(ftype) elif fid == 7: - if ftype == TType.I32: - self.replicaLocationCategory = iprot.readI32() + if ftype == TType.I64: + self.validUntilTime = iprot.readI64() else: iprot.skip(ftype) elif fid == 8: if ftype == TType.I32: - self.replicaPersistentType = iprot.readI32() + self.replicaLocationCategory = iprot.readI32() else: iprot.skip(ftype) elif fid == 9: - if ftype == TType.STRING: - self.storageResourceId = iprot.readString() + if ftype == TType.I32: + self.replicaPersistentType = iprot.readI32() else: iprot.skip(ftype) elif fid == 10: if ftype == TType.STRING: - self.storageResourceHostName = iprot.readString() + self.storageResourceId = iprot.readString() else: iprot.skip(ftype) elif fid == 11: - if ftype == TType.I32: - self.dataMovementProtocol = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.I64: - self.hostPort = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 13: - if ftype == TType.STRING: - self.filePath = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 14: if ftype == TType.STRING: - self.replicaUrl = iprot.readString() + self.fileAbsolutePath = iprot.readString() else: iprot.skip(ftype) - elif fid == 15: + elif fid == 12: if ftype == TType.MAP: self.replicaMetadata = {} (_ktype24, _vtype25, _size23 ) = iprot.readMapBegin() @@ -496,40 +472,28 @@ class DataReplicaLocationModel: oprot.writeFieldBegin('lastModifiedTime', TType.I64, 6) oprot.writeI64(self.lastModifiedTime) oprot.writeFieldEnd() + if self.validUntilTime is not None: + oprot.writeFieldBegin('validUntilTime', TType.I64, 7) + oprot.writeI64(self.validUntilTime) + oprot.writeFieldEnd() if self.replicaLocationCategory is not None: - oprot.writeFieldBegin('replicaLocationCategory', TType.I32, 7) + oprot.writeFieldBegin('replicaLocationCategory', TType.I32, 8) oprot.writeI32(self.replicaLocationCategory) oprot.writeFieldEnd() if self.replicaPersistentType is not None: - oprot.writeFieldBegin('replicaPersistentType', TType.I32, 8) + oprot.writeFieldBegin('replicaPersistentType', TType.I32, 9) oprot.writeI32(self.replicaPersistentType) oprot.writeFieldEnd() if self.storageResourceId is not None: - oprot.writeFieldBegin('storageResourceId', TType.STRING, 9) + oprot.writeFieldBegin('storageResourceId', TType.STRING, 10) oprot.writeString(self.storageResourceId) oprot.writeFieldEnd() - if self.storageResourceHostName is not None: - oprot.writeFieldBegin('storageResourceHostName', TType.STRING, 10) - oprot.writeString(self.storageResourceHostName) - oprot.writeFieldEnd() - if self.dataMovementProtocol is not None: - oprot.writeFieldBegin('dataMovementProtocol', TType.I32, 11) - oprot.writeI32(self.dataMovementProtocol) - oprot.writeFieldEnd() - if self.hostPort is not None: - oprot.writeFieldBegin('hostPort', TType.I64, 12) - oprot.writeI64(self.hostPort) - oprot.writeFieldEnd() - if self.filePath is not None: - oprot.writeFieldBegin('filePath', TType.STRING, 13) - oprot.writeString(self.filePath) - oprot.writeFieldEnd() - if self.replicaUrl is not None: - oprot.writeFieldBegin('replicaUrl', TType.STRING, 14) - oprot.writeString(self.replicaUrl) + if self.fileAbsolutePath is not None: + oprot.writeFieldBegin('fileAbsolutePath', TType.STRING, 11) + oprot.writeString(self.fileAbsolutePath) oprot.writeFieldEnd() if self.replicaMetadata is not None: - oprot.writeFieldBegin('replicaMetadata', TType.MAP, 15) + oprot.writeFieldBegin('replicaMetadata', TType.MAP, 12) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.replicaMetadata)) for kiter30,viter31 in self.replicaMetadata.items(): oprot.writeString(kiter30) @@ -551,14 +515,11 @@ class DataReplicaLocationModel: value = (value * 31) ^ hash(self.replicaDescription) value = (value * 31) ^ hash(self.creationTime) value = (value * 31) ^ hash(self.lastModifiedTime) + value = (value * 31) ^ hash(self.validUntilTime) value = (value * 31) ^ hash(self.replicaLocationCategory) value = (value * 31) ^ hash(self.replicaPersistentType) value = (value * 31) ^ hash(self.storageResourceId) - value = (value * 31) ^ hash(self.storageResourceHostName) - value = (value * 31) ^ hash(self.dataMovementProtocol) - value = (value * 31) ^ hash(self.hostPort) - value = (value * 31) ^ hash(self.filePath) - value = (value * 31) ^ hash(self.replicaUrl) + value = (value * 31) ^ hash(self.fileAbsolutePath) value = (value * 31) ^ hash(self.replicaMetadata) return value http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java index e5940f3..7d85e4d 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class Workflow implements org.apache.thrift.TBase<Workflow, Workflow._Fields>, java.io.Serializable, Cloneable, Comparable<Workflow> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Workflow"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java index c4baf26..9ba170e 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java @@ -77,7 +77,7 @@ import org.slf4j.LoggerFactory; * assigns to the environment variable "NAME" the value * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class ApplicationDeploymentDescription implements org.apache.thrift.TBase<ApplicationDeploymentDescription, ApplicationDeploymentDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationDeploymentDescription> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationDeploymentDescription"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java index 93d9ec0..4bbbcb1 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java @@ -66,7 +66,7 @@ import org.slf4j.LoggerFactory; * Descriprion of the Module * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class ApplicationModule implements org.apache.thrift.TBase<ApplicationModule, ApplicationModule._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationModule> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationModule"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java index bc14bde..a6082f9 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java @@ -60,7 +60,7 @@ import org.slf4j.LoggerFactory; * commandOrder: * Order of the command in the multiple command situation */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class CommandObject implements org.apache.thrift.TBase<CommandObject, CommandObject._Fields>, java.io.Serializable, Cloneable, Comparable<CommandObject> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommandObject"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java index 5949222..4f4f890 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java @@ -63,7 +63,7 @@ import org.slf4j.LoggerFactory; * envPathOrder: * The order of the setting of the env variables when there are multiple env variables */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class SetEnvPaths implements org.apache.thrift.TBase<SetEnvPaths, SetEnvPaths._Fields>, java.io.Serializable, Cloneable, Comparable<SetEnvPaths> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SetEnvPaths"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java index acec216..7fd67f4 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java @@ -64,7 +64,7 @@ import org.slf4j.LoggerFactory; * Outputs generated from the application * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class ApplicationInterfaceDescription implements org.apache.thrift.TBase<ApplicationInterfaceDescription, ApplicationInterfaceDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationInterfaceDescription> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationInterfaceDescription"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java index 6749794..3a28e89 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java @@ -57,7 +57,7 @@ import org.slf4j.LoggerFactory; * maxRunTime: * Maximum allowed run time in hours. */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class BatchQueue implements org.apache.thrift.TBase<BatchQueue, BatchQueue._Fields>, java.io.Serializable, Cloneable, Comparable<BatchQueue> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BatchQueue"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java index f71f782..dc9d87d 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java @@ -56,7 +56,7 @@ import org.slf4j.LoggerFactory; * * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class CloudJobSubmission implements org.apache.thrift.TBase<CloudJobSubmission, CloudJobSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<CloudJobSubmission> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CloudJobSubmission"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java index eed1231..c64b518 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java @@ -80,7 +80,7 @@ import org.slf4j.LoggerFactory; * Map of file systems type and the path. * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class ComputeResourceDescription implements org.apache.thrift.TBase<ComputeResourceDescription, ComputeResourceDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ComputeResourceDescription> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComputeResourceDescription"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java index 9bb6bdd..107e5aa 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class GlobusJobSubmission implements org.apache.thrift.TBase<GlobusJobSubmission, GlobusJobSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<GlobusJobSubmission> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GlobusJobSubmission"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java index 173a89a..361028d 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java @@ -61,7 +61,7 @@ import org.slf4j.LoggerFactory; * Lower the numerical number, higher the priority * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class JobSubmissionInterface implements org.apache.thrift.TBase<JobSubmissionInterface, JobSubmissionInterface._Fields>, java.io.Serializable, Cloneable, Comparable<JobSubmissionInterface> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobSubmissionInterface"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java index 875cf01..8204b4f 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java @@ -60,7 +60,7 @@ import org.slf4j.LoggerFactory; * sshPort: * If a non-default port needs to used, specify it. */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class LOCALSubmission implements org.apache.thrift.TBase<LOCALSubmission, LOCALSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<LOCALSubmission> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LOCALSubmission"); http://git-wip-us.apache.org/repos/asf/airavata/blob/36da4ee4/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ResourceJobManager.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ResourceJobManager.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ResourceJobManager.java index d1864e2..ca98c81 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ResourceJobManager.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ResourceJobManager.java @@ -68,7 +68,7 @@ import org.slf4j.LoggerFactory; * An enumeration of commonly used manager commands. * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-15") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-16") public class ResourceJobManager implements org.apache.thrift.TBase<ResourceJobManager, ResourceJobManager._Fields>, java.io.Serializable, Cloneable, Comparable<ResourceJobManager> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ResourceJobManager");
