You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/07/21 06:42:18 UTC
[35/44] airavata git commit: fixed all compilation errors in the java
client samples after the API changes.
http://git-wip-us.apache.org/repos/asf/airavata/blob/7be309d7/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 2fec726..680a7d6 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
@@ -180,7 +180,7 @@ class Iface:
"""
pass
- def getAllUserProjectsWithPagination(self, gatewayId, userName, limit, offset):
+ def getAllUserProjectsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
"""
* Get all Project by user with pagination. Results will be ordered based
* on creation time DESC
@@ -196,6 +196,7 @@ class Iface:
*
Parameters:
+ - authzToken
- gatewayId
- userName
- limit
@@ -222,7 +223,7 @@ class Iface:
"""
pass
- def searchProjectsByProjectNameWithPagination(self, gatewayId, userName, projectName, limit, offset):
+ def searchProjectsByProjectNameWithPagination(self, authzToken, gatewayId, userName, projectName, limit, offset):
"""
Get all Project for user by project name with pagination.Results will be ordered based
on creation time DESC
@@ -239,6 +240,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- projectName
@@ -265,7 +267,7 @@ class Iface:
"""
pass
- def searchProjectsByProjectDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def searchProjectsByProjectDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
"""
Search and get all Projects for user by project description with pagination. Results
will be ordered based on creation time DESC
@@ -282,6 +284,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- description
@@ -311,7 +314,7 @@ class Iface:
"""
pass
- def searchExperimentsByNameWithPagination(self, gatewayId, userName, expName, limit, offset):
+ def searchExperimentsByNameWithPagination(self, authzToken, gatewayId, userName, expName, limit, offset):
"""
Search Experiments by experiment name with pagination. Results will be sorted
based on creation time DESC
@@ -328,6 +331,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- expName
@@ -356,7 +360,7 @@ class Iface:
"""
pass
- def searchExperimentsByDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def searchExperimentsByDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
"""
Search Experiments by experiment name with pagination. Results will be sorted
based on creation time DESC
@@ -373,6 +377,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- description
@@ -401,7 +406,7 @@ class Iface:
"""
pass
- def searchExperimentsByApplicationWithPagination(self, gatewayId, userName, applicationId, limit, offset):
+ def searchExperimentsByApplicationWithPagination(self, authzToken, gatewayId, userName, applicationId, limit, offset):
"""
Search Experiments by application id with pagination. Results will be sorted
based on creation time DESC
@@ -418,6 +423,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- applicationId
@@ -446,7 +452,7 @@ class Iface:
"""
pass
- def searchExperimentsByStatusWithPagination(self, gatewayId, userName, experimentState, limit, offset):
+ def searchExperimentsByStatusWithPagination(self, authzToken, gatewayId, userName, experimentState, limit, offset):
"""
Search Experiments by experiment status with pagination. Results will be sorted
based on creation time DESC
@@ -463,6 +469,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- experimentState
@@ -494,7 +501,7 @@ class Iface:
"""
pass
- def searchExperimentsByCreationTimeWithPagination(self, gatewayId, userName, fromTime, toTime, limit, offset):
+ def searchExperimentsByCreationTimeWithPagination(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset):
"""
Search Experiments by experiment creation time with pagination. Results will be sorted
based on creation time DESC
@@ -513,6 +520,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- fromTime
@@ -522,7 +530,7 @@ class Iface:
"""
pass
- def searchExperiments(self, gatewayId, userName, filters, limit, offset):
+ def searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset):
"""
Search Experiments by using multiple filter criteria with pagination. Results will be sorted
based on creation time DESC
@@ -539,6 +547,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- filters
@@ -547,7 +556,7 @@ class Iface:
"""
pass
- def getExperimentStatistics(self, gatewayId, fromTime, toTime):
+ def getExperimentStatistics(self, authzToken, gatewayId, fromTime, toTime):
"""
Get Experiment Statisitics for the given gateway for a specific time period
@param gatewayId
@@ -559,6 +568,7 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
- fromTime
- toTime
@@ -579,7 +589,7 @@ class Iface:
"""
pass
- def getAllExperimentsInProjectWithPagination(self, projectId, limit, offset):
+ def getAllExperimentsInProjectWithPagination(self, authzToken, projectId, limit, offset):
"""
Get all Experiments within project with pagination. Results will be sorted
based on creation time DESC
@@ -592,6 +602,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- projectId
- limit
- offset
@@ -615,7 +626,7 @@ class Iface:
"""
pass
- def getAllUserExperimentsWithPagination(self, gatewayId, userName, limit, offset):
+ def getAllUserExperimentsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
"""
Get all Experiments by user pagination. Results will be sorted
based on creation time DESC
@@ -630,6 +641,7 @@ class Iface:
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- limit
@@ -637,7 +649,7 @@ class Iface:
"""
pass
- def createExperiment(self, gatewayId, experiment):
+ 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 authentication header. This experiment is just a persistent place holder. The client
@@ -674,12 +686,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
- experiment
"""
pass
- def getExperiment(self, airavataExperimentId):
+ def getExperiment(self, authzToken, airavataExperimentId):
"""
Fetch previously created experiment metadata.
@@ -714,11 +727,12 @@ class Iface:
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def updateExperiment(self, airavataExperimentId, experiment):
+ def updateExperiment(self, authzToken, airavataExperimentId, experiment):
"""
Configure a previously created experiment with required inputs, scheduling and other quality of service
parameters. This method only updates the experiment object within the registry. The experiment has to be launched
@@ -759,28 +773,31 @@ class Iface:
Parameters:
+ - authzToken
- airavataExperimentId
- experiment
"""
pass
- def updateExperimentConfiguration(self, airavataExperimentId, userConfiguration):
+ def updateExperimentConfiguration(self, authzToken, airavataExperimentId, userConfiguration):
"""
Parameters:
+ - authzToken
- airavataExperimentId
- userConfiguration
"""
pass
- def updateResourceScheduleing(self, airavataExperimentId, resourceScheduling):
+ def updateResourceScheduleing(self, authzToken, airavataExperimentId, resourceScheduling):
"""
Parameters:
+ - authzToken
- airavataExperimentId
- resourceScheduling
"""
pass
- def validateExperiment(self, airavataExperimentId):
+ def validateExperiment(self, authzToken, airavataExperimentId):
"""
*
* Validate experiment configuration. A true in general indicates, the experiment is ready to be launched.
@@ -791,11 +808,12 @@ class Iface:
*
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def launchExperiment(self, airavataExperimentId, airavataCredStoreToken):
+ def launchExperiment(self, authzToken, airavataExperimentId, airavataCredStoreToken):
"""
Launch a previously created and configured experiment. Airavata Server will then start processing the request and appropriate
notifications and intermediate and output data will be subsequently available for this experiment.
@@ -840,47 +858,53 @@ class Iface:
Parameters:
+ - authzToken
- airavataExperimentId
- airavataCredStoreToken
"""
pass
- def getExperimentStatus(self, airavataExperimentId):
+ def getExperimentStatus(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def getExperimentOutputs(self, airavataExperimentId):
+ def getExperimentOutputs(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def getIntermediateOutputs(self, airavataExperimentId):
+ def getIntermediateOutputs(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def getJobStatuses(self, airavataExperimentId):
+ def getJobStatuses(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def getJobDetails(self, airavataExperimentId):
+ def getJobDetails(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
pass
- def cloneExperiment(self, existingExperimentID, newExperimentName):
+ def cloneExperiment(self, authzToken, existingExperimentID, newExperimentName):
"""
Clone an specified experiment with a new name. A copy of the experiment configuration is made and is persisted with new metadata.
The client has to subsequently update this configuration if needed and launch the cloned experiment.
@@ -921,12 +945,13 @@ class Iface:
Parameters:
+ - authzToken
- existingExperimentID
- newExperimentName
"""
pass
- def terminateExperiment(self, airavataExperimentId, tokenId):
+ def terminateExperiment(self, authzToken, airavataExperimentId, tokenId):
"""
Terminate a running experiment.
@@ -961,12 +986,13 @@ class Iface:
Parameters:
+ - authzToken
- airavataExperimentId
- tokenId
"""
pass
- def registerApplicationModule(self, gatewayId, applicationModule):
+ def registerApplicationModule(self, authzToken, gatewayId, applicationModule):
"""
Register a Application Module.
@@ -978,12 +1004,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
- applicationModule
"""
pass
- def getApplicationModule(self, appModuleId):
+ def getApplicationModule(self, authzToken, appModuleId):
"""
Fetch a Application Module.
@@ -995,11 +1022,12 @@ class Iface:
Parameters:
+ - authzToken
- appModuleId
"""
pass
- def updateApplicationModule(self, appModuleId, applicationModule):
+ def updateApplicationModule(self, authzToken, appModuleId, applicationModule):
"""
Update a Application Module.
@@ -1014,19 +1042,21 @@ class Iface:
Parameters:
+ - authzToken
- appModuleId
- applicationModule
"""
pass
- def getAllAppModules(self, gatewayId):
+ def getAllAppModules(self, authzToken, gatewayId):
"""
Parameters:
+ - authzToken
- gatewayId
"""
pass
- def deleteApplicationModule(self, appModuleId):
+ def deleteApplicationModule(self, authzToken, appModuleId):
"""
Delete a Application Module.
@@ -1038,11 +1068,12 @@ class Iface:
Parameters:
+ - authzToken
- appModuleId
"""
pass
- def registerApplicationDeployment(self, gatewayId, applicationDeployment):
+ def registerApplicationDeployment(self, authzToken, gatewayId, applicationDeployment):
"""
Register a Application Deployment.
@@ -1054,12 +1085,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
- applicationDeployment
"""
pass
- def getApplicationDeployment(self, appDeploymentId):
+ def getApplicationDeployment(self, authzToken, appDeploymentId):
"""
Fetch a Application Deployment.
@@ -1071,11 +1103,12 @@ class Iface:
Parameters:
+ - authzToken
- appDeploymentId
"""
pass
- def updateApplicationDeployment(self, appDeploymentId, applicationDeployment):
+ def updateApplicationDeployment(self, authzToken, appDeploymentId, applicationDeployment):
"""
Update a Application Deployment.
@@ -1090,12 +1123,13 @@ class Iface:
Parameters:
+ - authzToken
- appDeploymentId
- applicationDeployment
"""
pass
- def deleteApplicationDeployment(self, appDeploymentId):
+ def deleteApplicationDeployment(self, authzToken, appDeploymentId):
"""
Delete a Application deployment.
@@ -1107,11 +1141,12 @@ class Iface:
Parameters:
+ - authzToken
- appDeploymentId
"""
pass
- def getAllApplicationDeployments(self, gatewayId):
+ def getAllApplicationDeployments(self, authzToken, gatewayId):
"""
Fetch all Application Deployment Descriptions.
@@ -1120,11 +1155,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
"""
pass
- def getAppModuleDeployedResources(self, appModuleId):
+ def getAppModuleDeployedResources(self, authzToken, appModuleId):
"""
Fetch a list of Deployed Compute Hosts.
@@ -1136,11 +1172,12 @@ class Iface:
Parameters:
+ - authzToken
- appModuleId
"""
pass
- def registerApplicationInterface(self, gatewayId, applicationInterface):
+ def registerApplicationInterface(self, authzToken, gatewayId, applicationInterface):
"""
Register a Application Interface.
@@ -1152,12 +1189,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
- applicationInterface
"""
pass
- def getApplicationInterface(self, appInterfaceId):
+ def getApplicationInterface(self, authzToken, appInterfaceId):
"""
Fetch a Application Interface.
@@ -1170,11 +1208,12 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
"""
pass
- def updateApplicationInterface(self, appInterfaceId, applicationInterface):
+ def updateApplicationInterface(self, authzToken, appInterfaceId, applicationInterface):
"""
Update a Application Interface.
@@ -1190,12 +1229,13 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
- applicationInterface
"""
pass
- def deleteApplicationInterface(self, appInterfaceId):
+ def deleteApplicationInterface(self, authzToken, appInterfaceId):
"""
Delete a Application Interface.
@@ -1208,11 +1248,12 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
"""
pass
- def getAllApplicationInterfaceNames(self, gatewayId):
+ def getAllApplicationInterfaceNames(self, authzToken, gatewayId):
"""
Fetch name and id of Application Interface documents.
@@ -1222,11 +1263,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
"""
pass
- def getAllApplicationInterfaces(self, gatewayId):
+ def getAllApplicationInterfaces(self, authzToken, gatewayId):
"""
Fetch all Application Interface documents.
@@ -1236,11 +1278,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayId
"""
pass
- def getApplicationInputs(self, appInterfaceId):
+ def getApplicationInputs(self, authzToken, appInterfaceId):
"""
Fetch the list of Application Inputs.
@@ -1252,11 +1295,12 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
"""
pass
- def getApplicationOutputs(self, appInterfaceId):
+ def getApplicationOutputs(self, authzToken, appInterfaceId):
"""
Fetch the list of Application Outputs.
@@ -1268,11 +1312,12 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
"""
pass
- def getAvailableAppInterfaceComputeResources(self, appInterfaceId):
+ def getAvailableAppInterfaceComputeResources(self, authzToken, appInterfaceId):
"""
Fetch a list of all deployed Compute Hosts for a given application interfaces.
@@ -1285,11 +1330,12 @@ class Iface:
Parameters:
+ - authzToken
- appInterfaceId
"""
pass
- def registerComputeResource(self, computeResourceDescription):
+ def registerComputeResource(self, authzToken, computeResourceDescription):
"""
Register a Compute Resource.
@@ -1301,11 +1347,12 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceDescription
"""
pass
- def getComputeResource(self, computeResourceId):
+ def getComputeResource(self, authzToken, computeResourceId):
"""
Fetch the given Compute Resource.
@@ -1317,21 +1364,25 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
"""
pass
- def getAllComputeResourceNames(self):
+ def getAllComputeResourceNames(self, authzToken):
"""
Fetch all registered Compute Resources.
@return A map of registered compute resource id's and thier corresponding hostnames.
Compute Resource Object created from the datamodel..
+
+ Parameters:
+ - authzToken
"""
pass
- def updateComputeResource(self, computeResourceId, computeResourceDescription):
+ def updateComputeResource(self, authzToken, computeResourceId, computeResourceDescription):
"""
Update a Compute Resource.
@@ -1346,12 +1397,13 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- computeResourceDescription
"""
pass
- def deleteComputeResource(self, computeResourceId):
+ def deleteComputeResource(self, authzToken, computeResourceId):
"""
Delete a Compute Resource.
@@ -1363,11 +1415,12 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
"""
pass
- def addLocalSubmissionDetails(self, computeResourceId, priorityOrder, localSubmission):
+ def addLocalSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, localSubmission):
"""
Add a Local Job Submission details to a compute resource
App catalog will return a jobSubmissionInterfaceId which will be added to the jobSubmissionInterfaces.
@@ -1386,13 +1439,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- localSubmission
"""
pass
- def updateLocalSubmissionDetails(self, jobSubmissionInterfaceId, localSubmission):
+ def updateLocalSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, localSubmission):
"""
Update the given Local Job Submission details
@@ -1407,12 +1461,13 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionInterfaceId
- localSubmission
"""
pass
- def getLocalJobSubmission(self, jobSubmissionId):
+ def getLocalJobSubmission(self, authzToken, jobSubmissionId):
"""
This method returns localJobSubmission object
@param jobSubmissionInterfaceId
@@ -1421,11 +1476,12 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionId
"""
pass
- def addSSHJobSubmissionDetails(self, computeResourceId, priorityOrder, sshJobSubmission):
+ def addSSHJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, sshJobSubmission):
"""
Add a SSH Job Submission details to a compute resource
App catalog will return a jobSubmissionInterfaceId which will be added to the jobSubmissionInterfaces.
@@ -1444,13 +1500,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- sshJobSubmission
"""
pass
- def getSSHJobSubmission(self, jobSubmissionId):
+ def getSSHJobSubmission(self, authzToken, jobSubmissionId):
"""
This method returns SSHJobSubmission object
@param jobSubmissionInterfaceId
@@ -1459,11 +1516,12 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionId
"""
pass
- def addUNICOREJobSubmissionDetails(self, computeResourceId, priorityOrder, unicoreJobSubmission):
+ def addUNICOREJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, unicoreJobSubmission):
"""
Add a UNICORE Job Submission details to a compute resource
App catalog will return a jobSubmissionInterfaceId which will be added to the jobSubmissionInterfaces.
@@ -1482,13 +1540,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- unicoreJobSubmission
"""
pass
- def getUnicoreJobSubmission(self, jobSubmissionId):
+ def getUnicoreJobSubmission(self, authzToken, jobSubmissionId):
"""
* This method returns UnicoreJobSubmission object
* @param jobSubmissionInterfaceId
@@ -1497,11 +1556,12 @@ class Iface:
*
Parameters:
+ - authzToken
- jobSubmissionId
"""
pass
- def addCloudJobSubmissionDetails(self, computeResourceId, priorityOrder, cloudSubmission):
+ def addCloudJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, cloudSubmission):
"""
* Add a Cloud Job Submission details to a compute resource
* App catalog will return a jobSubmissionInterfaceId which will be added to the jobSubmissionInterfaces.
@@ -1520,13 +1580,14 @@ class Iface:
*
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- cloudSubmission
"""
pass
- def getCloudJobSubmission(self, jobSubmissionId):
+ def getCloudJobSubmission(self, authzToken, jobSubmissionId):
"""
* This method returns cloudJobSubmission object
* @param jobSubmissionInterfaceI
@@ -1535,11 +1596,12 @@ class Iface:
*
Parameters:
+ - authzToken
- jobSubmissionId
"""
pass
- def updateSSHJobSubmissionDetails(self, jobSubmissionInterfaceId, sshJobSubmission):
+ def updateSSHJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, sshJobSubmission):
"""
Update the given SSH Job Submission details
@@ -1554,14 +1616,15 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionInterfaceId
- sshJobSubmission
"""
pass
- def updateCloudJobSubmissionDetails(self, jobSubmissionInterfaceId, sshJobSubmission):
+ def updateCloudJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, sshJobSubmission):
"""
- Update the given SSH Job Submission details
+ Update the cloud Job Submission details
@param jobSubmissionInterfaceId
The identifier of the JobSubmission Interface to be updated.
@@ -1574,20 +1637,22 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionInterfaceId
- sshJobSubmission
"""
pass
- def updateUnicoreJobSubmissionDetails(self, jobSubmissionInterfaceId, unicoreJobSubmission):
+ def updateUnicoreJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, unicoreJobSubmission):
"""
Parameters:
+ - authzToken
- jobSubmissionInterfaceId
- unicoreJobSubmission
"""
pass
- def addLocalDataMovementDetails(self, computeResourceId, priorityOrder, localDataMovement):
+ def addLocalDataMovementDetails(self, authzToken, computeResourceId, priorityOrder, localDataMovement):
"""
Add a Local data movement details to a compute resource
App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces.
@@ -1606,13 +1671,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- localDataMovement
"""
pass
- def updateLocalDataMovementDetails(self, dataMovementInterfaceId, localDataMovement):
+ def updateLocalDataMovementDetails(self, authzToken, dataMovementInterfaceId, localDataMovement):
"""
Update the given Local data movement details
@@ -1627,12 +1693,13 @@ class Iface:
Parameters:
+ - authzToken
- dataMovementInterfaceId
- localDataMovement
"""
pass
- def getLocalDataMovement(self, dataMovementId):
+ def getLocalDataMovement(self, authzToken, dataMovementId):
"""
* This method returns local datamovement object
* @param dataMovementId
@@ -1641,11 +1708,12 @@ class Iface:
*
Parameters:
+ - authzToken
- dataMovementId
"""
pass
- def addSCPDataMovementDetails(self, computeResourceId, priorityOrder, scpDataMovement):
+ def addSCPDataMovementDetails(self, authzToken, computeResourceId, priorityOrder, scpDataMovement):
"""
Add a SCP data movement details to a compute resource
App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces.
@@ -1664,13 +1732,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- scpDataMovement
"""
pass
- def updateSCPDataMovementDetails(self, dataMovementInterfaceId, scpDataMovement):
+ def updateSCPDataMovementDetails(self, authzToken, dataMovementInterfaceId, scpDataMovement):
"""
Update the given scp data movement details
App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces.
@@ -1686,12 +1755,13 @@ class Iface:
Parameters:
+ - authzToken
- dataMovementInterfaceId
- scpDataMovement
"""
pass
- def getSCPDataMovement(self, dataMovementId):
+ def getSCPDataMovement(self, authzToken, dataMovementId):
"""
* This method returns SCP datamovement object
* @param dataMovementId
@@ -1700,35 +1770,39 @@ class Iface:
*
Parameters:
+ - authzToken
- dataMovementId
"""
pass
- def addUnicoreDataMovementDetails(self, computeResourceId, priorityOrder, unicoreDataMovement):
+ def addUnicoreDataMovementDetails(self, authzToken, computeResourceId, priorityOrder, unicoreDataMovement):
"""
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- unicoreDataMovement
"""
pass
- def updateUnicoreDataMovementDetails(self, dataMovementInterfaceId, unicoreDataMovement):
+ def updateUnicoreDataMovementDetails(self, authzToken, dataMovementInterfaceId, unicoreDataMovement):
"""
Parameters:
+ - authzToken
- dataMovementInterfaceId
- unicoreDataMovement
"""
pass
- def getUnicoreDataMovement(self, dataMovementId):
+ def getUnicoreDataMovement(self, authzToken, dataMovementId):
"""
Parameters:
+ - authzToken
- dataMovementId
"""
pass
- def addGridFTPDataMovementDetails(self, computeResourceId, priorityOrder, gridFTPDataMovement):
+ def addGridFTPDataMovementDetails(self, authzToken, computeResourceId, priorityOrder, gridFTPDataMovement):
"""
Add a GridFTP data movement details to a compute resource
App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces.
@@ -1747,13 +1821,14 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- priorityOrder
- gridFTPDataMovement
"""
pass
- def updateGridFTPDataMovementDetails(self, dataMovementInterfaceId, gridFTPDataMovement):
+ def updateGridFTPDataMovementDetails(self, authzToken, dataMovementInterfaceId, gridFTPDataMovement):
"""
Update the given GridFTP data movement details to a compute resource
App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces.
@@ -1769,12 +1844,13 @@ class Iface:
Parameters:
+ - authzToken
- dataMovementInterfaceId
- gridFTPDataMovement
"""
pass
- def getGridFTPDataMovement(self, dataMovementId):
+ def getGridFTPDataMovement(self, authzToken, dataMovementId):
"""
* This method returns GridFTP datamovement object
* @param dataMovementId
@@ -1783,11 +1859,12 @@ class Iface:
*
Parameters:
+ - authzToken
- dataMovementId
"""
pass
- def changeJobSubmissionPriority(self, jobSubmissionInterfaceId, newPriorityOrder):
+ def changeJobSubmissionPriority(self, authzToken, jobSubmissionInterfaceId, newPriorityOrder):
"""
Change the priority of a given job submisison interface
@@ -1802,12 +1879,13 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionInterfaceId
- newPriorityOrder
"""
pass
- def changeDataMovementPriority(self, dataMovementInterfaceId, newPriorityOrder):
+ def changeDataMovementPriority(self, authzToken, dataMovementInterfaceId, newPriorityOrder):
"""
Change the priority of a given data movement interface
@@ -1822,12 +1900,13 @@ class Iface:
Parameters:
+ - authzToken
- dataMovementInterfaceId
- newPriorityOrder
"""
pass
- def changeJobSubmissionPriorities(self, jobSubmissionPriorityMap):
+ def changeJobSubmissionPriorities(self, authzToken, jobSubmissionPriorityMap):
"""
Change the priorities of a given set of job submission interfaces
@@ -1839,11 +1918,12 @@ class Iface:
Parameters:
+ - authzToken
- jobSubmissionPriorityMap
"""
pass
- def changeDataMovementPriorities(self, dataMovementPriorityMap):
+ def changeDataMovementPriorities(self, authzToken, dataMovementPriorityMap):
"""
Change the priorities of a given set of data movement interfaces
@@ -1855,11 +1935,12 @@ class Iface:
Parameters:
+ - authzToken
- dataMovementPriorityMap
"""
pass
- def deleteJobSubmissionInterface(self, computeResourceId, jobSubmissionInterfaceId):
+ def deleteJobSubmissionInterface(self, authzToken, computeResourceId, jobSubmissionInterfaceId):
"""
Delete a given job submisison interface
@@ -1871,12 +1952,13 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- jobSubmissionInterfaceId
"""
pass
- def deleteDataMovementInterface(self, computeResourceId, dataMovementInterfaceId):
+ def deleteDataMovementInterface(self, authzToken, computeResourceId, dataMovementInterfaceId):
"""
Delete a given data movement interface
@@ -1888,49 +1970,55 @@ class Iface:
Parameters:
+ - authzToken
- computeResourceId
- dataMovementInterfaceId
"""
pass
- def registerResourceJobManager(self, resourceJobManager):
+ def registerResourceJobManager(self, authzToken, resourceJobManager):
"""
Parameters:
+ - authzToken
- resourceJobManager
"""
pass
- def updateResourceJobManager(self, resourceJobManagerId, updatedResourceJobManager):
+ def updateResourceJobManager(self, authzToken, resourceJobManagerId, updatedResourceJobManager):
"""
Parameters:
+ - authzToken
- resourceJobManagerId
- updatedResourceJobManager
"""
pass
- def getResourceJobManager(self, resourceJobManagerId):
+ def getResourceJobManager(self, authzToken, resourceJobManagerId):
"""
Parameters:
+ - authzToken
- resourceJobManagerId
"""
pass
- def deleteResourceJobManager(self, resourceJobManagerId):
+ def deleteResourceJobManager(self, authzToken, resourceJobManagerId):
"""
Parameters:
+ - authzToken
- resourceJobManagerId
"""
pass
- def deleteBatchQueue(self, computeResourceId, queueName):
+ def deleteBatchQueue(self, authzToken, computeResourceId, queueName):
"""
Parameters:
+ - authzToken
- computeResourceId
- queueName
"""
pass
- def registerGatewayResourceProfile(self, gatewayResourceProfile):
+ def registerGatewayResourceProfile(self, authzToken, gatewayResourceProfile):
"""
Register a Gateway Resource Profile.
@@ -1944,11 +2032,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayResourceProfile
"""
pass
- def getGatewayResourceProfile(self, gatewayID):
+ def getGatewayResourceProfile(self, authzToken, gatewayID):
"""
Fetch the given Gateway Resource Profile.
@@ -1960,11 +2049,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
"""
pass
- def updateGatewayResourceProfile(self, gatewayID, gatewayResourceProfile):
+ def updateGatewayResourceProfile(self, authzToken, gatewayID, gatewayResourceProfile):
"""
Update a Gateway Resource Profile.
@@ -1979,12 +2069,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
- gatewayResourceProfile
"""
pass
- def deleteGatewayResourceProfile(self, gatewayID):
+ def deleteGatewayResourceProfile(self, authzToken, gatewayID):
"""
Delete the given Gateway Resource Profile.
@@ -1996,11 +2087,12 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
"""
pass
- def addGatewayComputeResourcePreference(self, gatewayID, computeResourceId, computeResourcePreference):
+ def addGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId, computeResourcePreference):
"""
Add a Compute Resource Preference to a registered gateway profile.
@@ -2019,13 +2111,14 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
- computeResourceId
- computeResourcePreference
"""
pass
- def getGatewayComputeResourcePreference(self, gatewayID, computeResourceId):
+ def getGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId):
"""
Fetch a Compute Resource Preference of a registered gateway profile.
@@ -2040,12 +2133,13 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
- computeResourceId
"""
pass
- def getAllGatewayComputeResourcePreferences(self, gatewayID):
+ def getAllGatewayComputeResourcePreferences(self, authzToken, gatewayID):
"""
Fetch all Compute Resource Preferences of a registered gateway profile.
@@ -2057,18 +2151,22 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
"""
pass
- def getAllGatewayComputeResources(self):
+ def getAllGatewayComputeResources(self, authzToken):
"""
Fetch all gateway profiles registered
+
+ Parameters:
+ - authzToken
"""
pass
- def updateGatewayComputeResourcePreference(self, gatewayID, computeResourceId, computeResourcePreference):
+ def updateGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId, computeResourcePreference):
"""
Update a Compute Resource Preference to a registered gateway profile.
@@ -2086,13 +2184,14 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
- computeResourceId
- computeResourcePreference
"""
pass
- def deleteGatewayComputeResourcePreference(self, gatewayID, computeResourceId):
+ def deleteGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId):
"""
Delete the Compute Resource Preference of a registered gateway profile.
@@ -2107,58 +2206,66 @@ class Iface:
Parameters:
+ - authzToken
- gatewayID
- computeResourceId
"""
pass
- def getAllWorkflows(self, gatewayId):
+ def getAllWorkflows(self, authzToken, gatewayId):
"""
Parameters:
+ - authzToken
- gatewayId
"""
pass
- def getWorkflow(self, workflowTemplateId):
+ def getWorkflow(self, authzToken, workflowTemplateId):
"""
Parameters:
+ - authzToken
- workflowTemplateId
"""
pass
- def deleteWorkflow(self, workflowTemplateId):
+ def deleteWorkflow(self, authzToken, workflowTemplateId):
"""
Parameters:
+ - authzToken
- workflowTemplateId
"""
pass
- def registerWorkflow(self, gatewayId, workflow):
+ def registerWorkflow(self, authzToken, gatewayId, workflow):
"""
Parameters:
+ - authzToken
- gatewayId
- workflow
"""
pass
- def updateWorkflow(self, workflowTemplateId, workflow):
+ def updateWorkflow(self, authzToken, workflowTemplateId, workflow):
"""
Parameters:
+ - authzToken
- workflowTemplateId
- workflow
"""
pass
- def getWorkflowTemplateId(self, workflowName):
+ def getWorkflowTemplateId(self, authzToken, workflowName):
"""
Parameters:
+ - authzToken
- workflowName
"""
pass
- def isWorkflowExistWithName(self, workflowName):
+ def isWorkflowExistWithName(self, authzToken, workflowName):
"""
Parameters:
+ - authzToken
- workflowName
"""
pass
@@ -2249,6 +2356,8 @@ class Client(Iface):
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, "addGateway failed: unknown result");
def updateGateway(self, authzToken, gatewayId, updatedGateway):
@@ -2288,6 +2397,8 @@ class Client(Iface):
raise result.ace
if result.ase is not None:
raise result.ase
+ if result.ae is not None:
+ raise result.ae
return
def getGateway(self, authzToken, gatewayId):
@@ -2327,6 +2438,8 @@ class Client(Iface):
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, "getGateway failed: unknown result");
def deleteGateway(self, authzToken, gatewayId):
@@ -2366,6 +2479,8 @@ class Client(Iface):
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, "deleteGateway failed: unknown result");
def getAllGateways(self, authzToken):
@@ -2403,6 +2518,8 @@ class Client(Iface):
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, "getAllGateways failed: unknown result");
def isGatewayExist(self, authzToken, gatewayId):
@@ -2442,6 +2559,8 @@ class Client(Iface):
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, "isGatewayExist failed: unknown result");
def generateAndRegisterSSHKeys(self, gatewayId, userName):
@@ -2621,6 +2740,8 @@ class Client(Iface):
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, "createProject failed: unknown result");
def updateProject(self, authzToken, projectId, updatedProject):
@@ -2665,6 +2786,8 @@ class Client(Iface):
raise result.ase
if result.pnfe is not None:
raise result.pnfe
+ if result.ae is not None:
+ raise result.ae
return
def getProject(self, authzToken, projectId):
@@ -2709,6 +2832,8 @@ class Client(Iface):
raise result.ase
if result.pnfe is not None:
raise result.pnfe
+ if result.ae is not None:
+ raise result.ae
raise TApplicationException(TApplicationException.MISSING_RESULT, "getProject failed: unknown result");
def deleteProject(self, authzToken, projectId):
@@ -2750,6 +2875,8 @@ class Client(Iface):
raise result.ase
if result.pnfe is not None:
raise result.pnfe
+ if result.ae is not None:
+ raise result.ae
raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteProject failed: unknown result");
def getAllUserProjects(self, gatewayId, userName):
@@ -2801,7 +2928,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUserProjects failed: unknown result");
- def getAllUserProjectsWithPagination(self, gatewayId, userName, limit, offset):
+ def getAllUserProjectsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
"""
* Get all Project by user with pagination. Results will be ordered based
* on creation time DESC
@@ -2817,17 +2944,19 @@ class Client(Iface):
*
Parameters:
+ - authzToken
- gatewayId
- userName
- limit
- offset
"""
- self.send_getAllUserProjectsWithPagination(gatewayId, userName, limit, offset)
+ self.send_getAllUserProjectsWithPagination(authzToken, gatewayId, userName, limit, offset)
return self.recv_getAllUserProjectsWithPagination()
- def send_getAllUserProjectsWithPagination(self, gatewayId, userName, limit, offset):
+ def send_getAllUserProjectsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
self._oprot.writeMessageBegin('getAllUserProjectsWithPagination', TMessageType.CALL, self._seqid)
args = getAllUserProjectsWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.limit = limit
@@ -2855,6 +2984,8 @@ class Client(Iface):
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, "getAllUserProjectsWithPagination failed: unknown result");
def searchProjectsByProjectName(self, gatewayId, userName, projectName):
@@ -2908,7 +3039,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectName failed: unknown result");
- def searchProjectsByProjectNameWithPagination(self, gatewayId, userName, projectName, limit, offset):
+ def searchProjectsByProjectNameWithPagination(self, authzToken, gatewayId, userName, projectName, limit, offset):
"""
Get all Project for user by project name with pagination.Results will be ordered based
on creation time DESC
@@ -2925,18 +3056,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- projectName
- limit
- offset
"""
- self.send_searchProjectsByProjectNameWithPagination(gatewayId, userName, projectName, limit, offset)
+ self.send_searchProjectsByProjectNameWithPagination(authzToken, gatewayId, userName, projectName, limit, offset)
return self.recv_searchProjectsByProjectNameWithPagination()
- def send_searchProjectsByProjectNameWithPagination(self, gatewayId, userName, projectName, limit, offset):
+ def send_searchProjectsByProjectNameWithPagination(self, authzToken, gatewayId, userName, projectName, limit, offset):
self._oprot.writeMessageBegin('searchProjectsByProjectNameWithPagination', TMessageType.CALL, self._seqid)
args = searchProjectsByProjectNameWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.projectName = projectName
@@ -2965,6 +3098,8 @@ class Client(Iface):
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, "searchProjectsByProjectNameWithPagination failed: unknown result");
def searchProjectsByProjectDesc(self, gatewayId, userName, description):
@@ -3017,7 +3152,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result");
- def searchProjectsByProjectDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def searchProjectsByProjectDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
"""
Search and get all Projects for user by project description with pagination. Results
will be ordered based on creation time DESC
@@ -3034,18 +3169,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- description
- limit
- offset
"""
- self.send_searchProjectsByProjectDescWithPagination(gatewayId, userName, description, limit, offset)
+ self.send_searchProjectsByProjectDescWithPagination(authzToken, gatewayId, userName, description, limit, offset)
return self.recv_searchProjectsByProjectDescWithPagination()
- def send_searchProjectsByProjectDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def send_searchProjectsByProjectDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
self._oprot.writeMessageBegin('searchProjectsByProjectDescWithPagination', TMessageType.CALL, self._seqid)
args = searchProjectsByProjectDescWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.description = description
@@ -3074,6 +3211,8 @@ class Client(Iface):
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, "searchProjectsByProjectDescWithPagination failed: unknown result");
def searchExperimentsByName(self, gatewayId, userName, expName):
@@ -3129,7 +3268,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByName failed: unknown result");
- def searchExperimentsByNameWithPagination(self, gatewayId, userName, expName, limit, offset):
+ def searchExperimentsByNameWithPagination(self, authzToken, gatewayId, userName, expName, limit, offset):
"""
Search Experiments by experiment name with pagination. Results will be sorted
based on creation time DESC
@@ -3146,18 +3285,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- expName
- limit
- offset
"""
- self.send_searchExperimentsByNameWithPagination(gatewayId, userName, expName, limit, offset)
+ self.send_searchExperimentsByNameWithPagination(authzToken, gatewayId, userName, expName, limit, offset)
return self.recv_searchExperimentsByNameWithPagination()
- def send_searchExperimentsByNameWithPagination(self, gatewayId, userName, expName, limit, offset):
+ def send_searchExperimentsByNameWithPagination(self, authzToken, gatewayId, userName, expName, limit, offset):
self._oprot.writeMessageBegin('searchExperimentsByNameWithPagination', TMessageType.CALL, self._seqid)
args = searchExperimentsByNameWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.expName = expName
@@ -3186,6 +3327,8 @@ class Client(Iface):
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, "searchExperimentsByNameWithPagination failed: unknown result");
def searchExperimentsByDesc(self, gatewayId, userName, description):
@@ -3240,7 +3383,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByDesc failed: unknown result");
- def searchExperimentsByDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def searchExperimentsByDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
"""
Search Experiments by experiment name with pagination. Results will be sorted
based on creation time DESC
@@ -3257,18 +3400,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- description
- limit
- offset
"""
- self.send_searchExperimentsByDescWithPagination(gatewayId, userName, description, limit, offset)
+ self.send_searchExperimentsByDescWithPagination(authzToken, gatewayId, userName, description, limit, offset)
return self.recv_searchExperimentsByDescWithPagination()
- def send_searchExperimentsByDescWithPagination(self, gatewayId, userName, description, limit, offset):
+ def send_searchExperimentsByDescWithPagination(self, authzToken, gatewayId, userName, description, limit, offset):
self._oprot.writeMessageBegin('searchExperimentsByDescWithPagination', TMessageType.CALL, self._seqid)
args = searchExperimentsByDescWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.description = description
@@ -3297,6 +3442,8 @@ class Client(Iface):
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, "searchExperimentsByDescWithPagination failed: unknown result");
def searchExperimentsByApplication(self, gatewayId, userName, applicationId):
@@ -3351,7 +3498,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByApplication failed: unknown result");
- def searchExperimentsByApplicationWithPagination(self, gatewayId, userName, applicationId, limit, offset):
+ def searchExperimentsByApplicationWithPagination(self, authzToken, gatewayId, userName, applicationId, limit, offset):
"""
Search Experiments by application id with pagination. Results will be sorted
based on creation time DESC
@@ -3368,18 +3515,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- applicationId
- limit
- offset
"""
- self.send_searchExperimentsByApplicationWithPagination(gatewayId, userName, applicationId, limit, offset)
+ self.send_searchExperimentsByApplicationWithPagination(authzToken, gatewayId, userName, applicationId, limit, offset)
return self.recv_searchExperimentsByApplicationWithPagination()
- def send_searchExperimentsByApplicationWithPagination(self, gatewayId, userName, applicationId, limit, offset):
+ def send_searchExperimentsByApplicationWithPagination(self, authzToken, gatewayId, userName, applicationId, limit, offset):
self._oprot.writeMessageBegin('searchExperimentsByApplicationWithPagination', TMessageType.CALL, self._seqid)
args = searchExperimentsByApplicationWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.applicationId = applicationId
@@ -3408,6 +3557,8 @@ class Client(Iface):
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, "searchExperimentsByApplicationWithPagination failed: unknown result");
def searchExperimentsByStatus(self, gatewayId, userName, experimentState):
@@ -3462,7 +3613,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result");
- def searchExperimentsByStatusWithPagination(self, gatewayId, userName, experimentState, limit, offset):
+ def searchExperimentsByStatusWithPagination(self, authzToken, gatewayId, userName, experimentState, limit, offset):
"""
Search Experiments by experiment status with pagination. Results will be sorted
based on creation time DESC
@@ -3479,18 +3630,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- experimentState
- limit
- offset
"""
- self.send_searchExperimentsByStatusWithPagination(gatewayId, userName, experimentState, limit, offset)
+ self.send_searchExperimentsByStatusWithPagination(authzToken, gatewayId, userName, experimentState, limit, offset)
return self.recv_searchExperimentsByStatusWithPagination()
- def send_searchExperimentsByStatusWithPagination(self, gatewayId, userName, experimentState, limit, offset):
+ def send_searchExperimentsByStatusWithPagination(self, authzToken, gatewayId, userName, experimentState, limit, offset):
self._oprot.writeMessageBegin('searchExperimentsByStatusWithPagination', TMessageType.CALL, self._seqid)
args = searchExperimentsByStatusWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.experimentState = experimentState
@@ -3519,6 +3672,8 @@ class Client(Iface):
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, "searchExperimentsByStatusWithPagination failed: unknown result");
def searchExperimentsByCreationTime(self, gatewayId, userName, fromTime, toTime):
@@ -3577,7 +3732,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByCreationTime failed: unknown result");
- def searchExperimentsByCreationTimeWithPagination(self, gatewayId, userName, fromTime, toTime, limit, offset):
+ def searchExperimentsByCreationTimeWithPagination(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset):
"""
Search Experiments by experiment creation time with pagination. Results will be sorted
based on creation time DESC
@@ -3596,6 +3751,7 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- fromTime
@@ -3603,12 +3759,13 @@ class Client(Iface):
- limit
- offset
"""
- self.send_searchExperimentsByCreationTimeWithPagination(gatewayId, userName, fromTime, toTime, limit, offset)
+ self.send_searchExperimentsByCreationTimeWithPagination(authzToken, gatewayId, userName, fromTime, toTime, limit, offset)
return self.recv_searchExperimentsByCreationTimeWithPagination()
- def send_searchExperimentsByCreationTimeWithPagination(self, gatewayId, userName, fromTime, toTime, limit, offset):
+ def send_searchExperimentsByCreationTimeWithPagination(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset):
self._oprot.writeMessageBegin('searchExperimentsByCreationTimeWithPagination', TMessageType.CALL, self._seqid)
args = searchExperimentsByCreationTimeWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.fromTime = fromTime
@@ -3638,9 +3795,11 @@ class Client(Iface):
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, "searchExperimentsByCreationTimeWithPagination failed: unknown result");
- def searchExperiments(self, gatewayId, userName, filters, limit, offset):
+ def searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset):
"""
Search Experiments by using multiple filter criteria with pagination. Results will be sorted
based on creation time DESC
@@ -3657,18 +3816,20 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- filters
- limit
- offset
"""
- self.send_searchExperiments(gatewayId, userName, filters, limit, offset)
+ self.send_searchExperiments(authzToken, gatewayId, userName, filters, limit, offset)
return self.recv_searchExperiments()
- def send_searchExperiments(self, gatewayId, userName, filters, limit, offset):
+ def send_searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset):
self._oprot.writeMessageBegin('searchExperiments', TMessageType.CALL, self._seqid)
args = searchExperiments_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.filters = filters
@@ -3697,9 +3858,11 @@ class Client(Iface):
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, "searchExperiments failed: unknown result");
- def getExperimentStatistics(self, gatewayId, fromTime, toTime):
+ def getExperimentStatistics(self, authzToken, gatewayId, fromTime, toTime):
"""
Get Experiment Statisitics for the given gateway for a specific time period
@param gatewayId
@@ -3711,16 +3874,18 @@ class Client(Iface):
Parameters:
+ - authzToken
- gatewayId
- fromTime
- toTime
"""
- self.send_getExperimentStatistics(gatewayId, fromTime, toTime)
+ self.send_getExperimentStatistics(authzToken, gatewayId, fromTime, toTime)
return self.recv_getExperimentStatistics()
- def send_getExperimentStatistics(self, gatewayId, fromTime, toTime):
+ def send_getExperimentStatistics(self, authzToken, gatewayId, fromTime, toTime):
self._oprot.writeMessageBegin('getExperimentStatistics', TMessageType.CALL, self._seqid)
args = getExperimentStatistics_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.fromTime = fromTime
args.toTime = toTime
@@ -3747,6 +3912,8 @@ class Client(Iface):
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, "getExperimentStatistics failed: unknown result");
def getAllExperimentsInProject(self, projectId):
@@ -3795,7 +3962,7 @@ class Client(Iface):
raise result.pnfe
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllExperimentsInProject failed: unknown result");
- def getAllExperimentsInProjectWithPagination(self, projectId, limit, offset):
+ def getAllExperimentsInProjectWithPagination(self, authzToken, projectId, limit, offset):
"""
Get all Experiments within project with pagination. Results will be sorted
based on creation time DESC
@@ -3808,16 +3975,18 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- projectId
- limit
- offset
"""
- self.send_getAllExperimentsInProjectWithPagination(projectId, limit, offset)
+ self.send_getAllExperimentsInProjectWithPagination(authzToken, projectId, limit, offset)
return self.recv_getAllExperimentsInProjectWithPagination()
- def send_getAllExperimentsInProjectWithPagination(self, projectId, limit, offset):
+ def send_getAllExperimentsInProjectWithPagination(self, authzToken, projectId, limit, offset):
self._oprot.writeMessageBegin('getAllExperimentsInProjectWithPagination', TMessageType.CALL, self._seqid)
args = getAllExperimentsInProjectWithPagination_args()
+ args.authzToken = authzToken
args.projectId = projectId
args.limit = limit
args.offset = offset
@@ -3846,6 +4015,8 @@ class Client(Iface):
raise result.ase
if result.pnfe is not None:
raise result.pnfe
+ if result.ae is not None:
+ raise result.ae
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllExperimentsInProjectWithPagination failed: unknown result");
def getAllUserExperiments(self, gatewayId, userName):
@@ -3896,7 +4067,7 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUserExperiments failed: unknown result");
- def getAllUserExperimentsWithPagination(self, gatewayId, userName, limit, offset):
+ def getAllUserExperimentsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
"""
Get all Experiments by user pagination. Results will be sorted
based on creation time DESC
@@ -3911,17 +4082,19 @@ class Client(Iface):
The starting point of the results to be fetched
Parameters:
+ - authzToken
- gatewayId
- userName
- limit
- offset
"""
- self.send_getAllUserExperimentsWithPagination(gatewayId, userName, limit, offset)
+ self.send_getAllUserExperimentsWithPagination(authzToken, gatewayId, userName, limit, offset)
return self.recv_getAllUserExperimentsWithPagination()
- def send_getAllUserExperimentsWithPagination(self, gatewayId, userName, limit, offset):
+ def send_getAllUserExperimentsWithPagination(self, authzToken, gatewayId, userName, limit, offset):
self._oprot.writeMessageBegin('getAllUserExperimentsWithPagination', TMessageType.CALL, self._seqid)
args = getAllUserExperimentsWithPagination_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.userName = userName
args.limit = limit
@@ -3949,9 +4122,11 @@ class Client(Iface):
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, "getAllUserExperimentsWithPagination failed: unknown result");
- def createExperiment(self, gatewayId, experiment):
+ 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 authentication header. This experiment is just a persistent place holder. The client
@@ -3988,15 +4163,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- gatewayId
- experiment
"""
- self.send_createExperiment(gatewayId, experiment)
+ self.send_createExperiment(authzToken, gatewayId, experiment)
return self.recv_createExperiment()
- def send_createExperiment(self, gatewayId, experiment):
+ def send_createExperiment(self, authzToken, gatewayId, experiment):
self._oprot.writeMessageBegin('createExperiment', TMessageType.CALL, self._seqid)
args = createExperiment_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.experiment = experiment
args.write(self._oprot)
@@ -4022,9 +4199,11 @@ class Client(Iface):
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, "createExperiment failed: unknown result");
- def getExperiment(self, airavataExperimentId):
+ def getExperiment(self, authzToken, airavataExperimentId):
"""
Fetch previously created experiment metadata.
@@ -4059,14 +4238,16 @@ class Client(Iface):
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getExperiment(airavataExperimentId)
+ self.send_getExperiment(authzToken, airavataExperimentId)
return self.recv_getExperiment()
- def send_getExperiment(self, airavataExperimentId):
+ def send_getExperiment(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getExperiment', TMessageType.CALL, self._seqid)
args = getExperiment_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4093,9 +4274,11 @@ class Client(Iface):
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, "getExperiment failed: unknown result");
- def updateExperiment(self, airavataExperimentId, experiment):
+ def updateExperiment(self, authzToken, airavataExperimentId, experiment):
"""
Configure a previously created experiment with required inputs, scheduling and other quality of service
parameters. This method only updates the experiment object within the registry. The experiment has to be launched
@@ -4136,15 +4319,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- airavataExperimentId
- experiment
"""
- self.send_updateExperiment(airavataExperimentId, experiment)
+ self.send_updateExperiment(authzToken, airavataExperimentId, experiment)
self.recv_updateExperiment()
- def send_updateExperiment(self, airavataExperimentId, experiment):
+ def send_updateExperiment(self, authzToken, airavataExperimentId, experiment):
self._oprot.writeMessageBegin('updateExperiment', TMessageType.CALL, self._seqid)
args = updateExperiment_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.experiment = experiment
args.write(self._oprot)
@@ -4170,20 +4355,24 @@ class Client(Iface):
raise result.ace
if result.ase is not None:
raise result.ase
+ if result.ae is not None:
+ raise result.ae
return
- def updateExperimentConfiguration(self, airavataExperimentId, userConfiguration):
+ def updateExperimentConfiguration(self, authzToken, airavataExperimentId, userConfiguration):
"""
Parameters:
+ - authzToken
- airavataExperimentId
- userConfiguration
"""
- self.send_updateExperimentConfiguration(airavataExperimentId, userConfiguration)
+ self.send_updateExperimentConfiguration(authzToken, airavataExperimentId, userConfiguration)
self.recv_updateExperimentConfiguration()
- def send_updateExperimentConfiguration(self, airavataExperimentId, userConfiguration):
+ def send_updateExperimentConfiguration(self, authzToken, airavataExperimentId, userConfiguration):
self._oprot.writeMessageBegin('updateExperimentConfiguration', TMessageType.CALL, self._seqid)
args = updateExperimentConfiguration_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.userConfiguration = userConfiguration
args.write(self._oprot)
@@ -4201,20 +4390,24 @@ class Client(Iface):
result = updateExperimentConfiguration_result()
result.read(iprot)
iprot.readMessageEnd()
+ if result.ae is not None:
+ raise result.ae
return
- def updateResourceScheduleing(self, airavataExperimentId, resourceScheduling):
+ def updateResourceScheduleing(self, authzToken, airavataExperimentId, resourceScheduling):
"""
Parameters:
+ - authzToken
- airavataExperimentId
- resourceScheduling
"""
- self.send_updateResourceScheduleing(airavataExperimentId, resourceScheduling)
+ self.send_updateResourceScheduleing(authzToken, airavataExperimentId, resourceScheduling)
self.recv_updateResourceScheduleing()
- def send_updateResourceScheduleing(self, airavataExperimentId, resourceScheduling):
+ def send_updateResourceScheduleing(self, authzToken, airavataExperimentId, resourceScheduling):
self._oprot.writeMessageBegin('updateResourceScheduleing', TMessageType.CALL, self._seqid)
args = updateResourceScheduleing_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.resourceScheduling = resourceScheduling
args.write(self._oprot)
@@ -4232,9 +4425,11 @@ class Client(Iface):
result = updateResourceScheduleing_result()
result.read(iprot)
iprot.readMessageEnd()
+ if result.ae is not None:
+ raise result.ae
return
- def validateExperiment(self, airavataExperimentId):
+ def validateExperiment(self, authzToken, airavataExperimentId):
"""
*
* Validate experiment configuration. A true in general indicates, the experiment is ready to be launched.
@@ -4245,14 +4440,16 @@ class Client(Iface):
*
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_validateExperiment(airavataExperimentId)
+ self.send_validateExperiment(authzToken, airavataExperimentId)
return self.recv_validateExperiment()
- def send_validateExperiment(self, airavataExperimentId):
+ def send_validateExperiment(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('validateExperiment', TMessageType.CALL, self._seqid)
args = validateExperiment_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4279,9 +4476,11 @@ class Client(Iface):
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, "validateExperiment failed: unknown result");
- def launchExperiment(self, airavataExperimentId, airavataCredStoreToken):
+ def launchExperiment(self, authzToken, airavataExperimentId, airavataCredStoreToken):
"""
Launch a previously created and configured experiment. Airavata Server will then start processing the request and appropriate
notifications and intermediate and output data will be subsequently available for this experiment.
@@ -4326,15 +4525,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- airavataExperimentId
- airavataCredStoreToken
"""
- self.send_launchExperiment(airavataExperimentId, airavataCredStoreToken)
+ self.send_launchExperiment(authzToken, airavataExperimentId, airavataCredStoreToken)
self.recv_launchExperiment()
- def send_launchExperiment(self, airavataExperimentId, airavataCredStoreToken):
+ def send_launchExperiment(self, authzToken, airavataExperimentId, airavataCredStoreToken):
self._oprot.writeMessageBegin('launchExperiment', TMessageType.CALL, self._seqid)
args = launchExperiment_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.airavataCredStoreToken = airavataCredStoreToken
args.write(self._oprot)
@@ -4360,19 +4561,23 @@ class Client(Iface):
raise result.ace
if result.ase is not None:
raise result.ase
+ if result.ae is not None:
+ raise result.ae
return
- def getExperimentStatus(self, airavataExperimentId):
+ def getExperimentStatus(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getExperimentStatus(airavataExperimentId)
+ self.send_getExperimentStatus(authzToken, airavataExperimentId)
return self.recv_getExperimentStatus()
- def send_getExperimentStatus(self, airavataExperimentId):
+ def send_getExperimentStatus(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getExperimentStatus', TMessageType.CALL, self._seqid)
args = getExperimentStatus_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4399,19 +4604,23 @@ class Client(Iface):
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, "getExperimentStatus failed: unknown result");
- def getExperimentOutputs(self, airavataExperimentId):
+ def getExperimentOutputs(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getExperimentOutputs(airavataExperimentId)
+ self.send_getExperimentOutputs(authzToken, airavataExperimentId)
return self.recv_getExperimentOutputs()
- def send_getExperimentOutputs(self, airavataExperimentId):
+ def send_getExperimentOutputs(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getExperimentOutputs', TMessageType.CALL, self._seqid)
args = getExperimentOutputs_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4438,19 +4647,23 @@ class Client(Iface):
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, "getExperimentOutputs failed: unknown result");
- def getIntermediateOutputs(self, airavataExperimentId):
+ def getIntermediateOutputs(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getIntermediateOutputs(airavataExperimentId)
+ self.send_getIntermediateOutputs(authzToken, airavataExperimentId)
return self.recv_getIntermediateOutputs()
- def send_getIntermediateOutputs(self, airavataExperimentId):
+ def send_getIntermediateOutputs(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getIntermediateOutputs', TMessageType.CALL, self._seqid)
args = getIntermediateOutputs_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4477,19 +4690,23 @@ class Client(Iface):
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, "getIntermediateOutputs failed: unknown result");
- def getJobStatuses(self, airavataExperimentId):
+ def getJobStatuses(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getJobStatuses(airavataExperimentId)
+ self.send_getJobStatuses(authzToken, airavataExperimentId)
return self.recv_getJobStatuses()
- def send_getJobStatuses(self, airavataExperimentId):
+ def send_getJobStatuses(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getJobStatuses', TMessageType.CALL, self._seqid)
args = getJobStatuses_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4516,19 +4733,23 @@ class Client(Iface):
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, "getJobStatuses failed: unknown result");
- def getJobDetails(self, airavataExperimentId):
+ def getJobDetails(self, authzToken, airavataExperimentId):
"""
Parameters:
+ - authzToken
- airavataExperimentId
"""
- self.send_getJobDetails(airavataExperimentId)
+ self.send_getJobDetails(authzToken, airavataExperimentId)
return self.recv_getJobDetails()
- def send_getJobDetails(self, airavataExperimentId):
+ def send_getJobDetails(self, authzToken, airavataExperimentId):
self._oprot.writeMessageBegin('getJobDetails', TMessageType.CALL, self._seqid)
args = getJobDetails_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4555,9 +4776,11 @@ class Client(Iface):
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, "getJobDetails failed: unknown result");
- def cloneExperiment(self, existingExperimentID, newExperimentName):
+ def cloneExperiment(self, authzToken, existingExperimentID, newExperimentName):
"""
Clone an specified experiment with a new name. A copy of the experiment configuration is made and is persisted with new metadata.
The client has to subsequently update this configuration if needed and launch the cloned experiment.
@@ -4598,15 +4821,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- existingExperimentID
- newExperimentName
"""
- self.send_cloneExperiment(existingExperimentID, newExperimentName)
+ self.send_cloneExperiment(authzToken, existingExperimentID, newExperimentName)
return self.recv_cloneExperiment()
- def send_cloneExperiment(self, existingExperimentID, newExperimentName):
+ def send_cloneExperiment(self, authzToken, existingExperimentID, newExperimentName):
self._oprot.writeMessageBegin('cloneExperiment', TMessageType.CALL, self._seqid)
args = cloneExperiment_args()
+ args.authzToken = authzToken
args.existingExperimentID = existingExperimentID
args.newExperimentName = newExperimentName
args.write(self._oprot)
@@ -4634,9 +4859,11 @@ class Client(Iface):
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, "cloneExperiment failed: unknown result");
- def terminateExperiment(self, airavataExperimentId, tokenId):
+ def terminateExperiment(self, authzToken, airavataExperimentId, tokenId):
"""
Terminate a running experiment.
@@ -4671,15 +4898,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- airavataExperimentId
- tokenId
"""
- self.send_terminateExperiment(airavataExperimentId, tokenId)
+ self.send_terminateExperiment(authzToken, airavataExperimentId, tokenId)
self.recv_terminateExperiment()
- def send_terminateExperiment(self, airavataExperimentId, tokenId):
+ def send_terminateExperiment(self, authzToken, airavataExperimentId, tokenId):
self._oprot.writeMessageBegin('terminateExperiment', TMessageType.CALL, self._seqid)
args = terminateExperiment_args()
+ args.authzToken = authzToken
args.airavataExperimentId = airavataExperimentId
args.tokenId = tokenId
args.write(self._oprot)
@@ -4705,9 +4934,11 @@ class Client(Iface):
raise result.ace
if result.ase is not None:
raise result.ase
+ if result.ae is not None:
+ raise result.ae
return
- def registerApplicationModule(self, gatewayId, applicationModule):
+ def registerApplicationModule(self, authzToken, gatewayId, applicationModule):
"""
Register a Application Module.
@@ -4719,15 +4950,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- gatewayId
- applicationModule
"""
- self.send_registerApplicationModule(gatewayId, applicationModule)
+ self.send_registerApplicationModule(authzToken, gatewayId, applicationModule)
return self.recv_registerApplicationModule()
- def send_registerApplicationModule(self, gatewayId, applicationModule):
+ def send_registerApplicationModule(self, authzToken, gatewayId, applicationModule):
self._oprot.writeMessageBegin('registerApplicationModule', TMessageType.CALL, self._seqid)
args = registerApplicationModule_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.applicationModule = applicationModule
args.write(self._oprot)
@@ -4753,9 +4986,11 @@ class Client(Iface):
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, "registerApplicationModule failed: unknown result");
- def getApplicationModule(self, appModuleId):
+ def getApplicationModule(self, authzToken, appModuleId):
"""
Fetch a Application Module.
@@ -4767,14 +5002,16 @@ class Client(Iface):
Parameters:
+ - authzToken
- appModuleId
"""
- self.send_getApplicationModule(appModuleId)
+ self.send_getApplicationModule(authzToken, appModuleId)
return self.recv_getApplicationModule()
- def send_getApplicationModule(self, appModuleId):
+ def send_getApplicationModule(self, authzToken, appModuleId):
self._oprot.writeMessageBegin('getApplicationModule', TMessageType.CALL, self._seqid)
args = getApplicationModule_args()
+ args.authzToken = authzToken
args.appModuleId = appModuleId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4799,9 +5036,11 @@ class Client(Iface):
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, "getApplicationModule failed: unknown result");
- def updateApplicationModule(self, appModuleId, applicationModule):
+ def updateApplicationModule(self, authzToken, appModuleId, applicationModule):
"""
Update a Application Module.
@@ -4816,15 +5055,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- appModuleId
- applicationModule
"""
- self.send_updateApplicationModule(appModuleId, applicationModule)
+ self.send_updateApplicationModule(authzToken, appModuleId, applicationModule)
return self.recv_updateApplicationModule()
- def send_updateApplicationModule(self, appModuleId, applicationModule):
+ def send_updateApplicationModule(self, authzToken, appModuleId, applicationModule):
self._oprot.writeMessageBegin('updateApplicationModule', TMessageType.CALL, self._seqid)
args = updateApplicationModule_args()
+ args.authzToken = authzToken
args.appModuleId = appModuleId
args.applicationModule = applicationModule
args.write(self._oprot)
@@ -4850,19 +5091,23 @@ class Client(Iface):
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, "updateApplicationModule failed: unknown result");
- def getAllAppModules(self, gatewayId):
+ def getAllAppModules(self, authzToken, gatewayId):
"""
Parameters:
+ - authzToken
- gatewayId
"""
- self.send_getAllAppModules(gatewayId)
+ self.send_getAllAppModules(authzToken, gatewayId)
return self.recv_getAllAppModules()
- def send_getAllAppModules(self, gatewayId):
+ def send_getAllAppModules(self, authzToken, gatewayId):
self._oprot.writeMessageBegin('getAllAppModules', TMessageType.CALL, self._seqid)
args = getAllAppModules_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4887,9 +5132,11 @@ class Client(Iface):
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, "getAllAppModules failed: unknown result");
- def deleteApplicationModule(self, appModuleId):
+ def deleteApplicationModule(self, authzToken, appModuleId):
"""
Delete a Application Module.
@@ -4901,14 +5148,16 @@ class Client(Iface):
Parameters:
+ - authzToken
- appModuleId
"""
- self.send_deleteApplicationModule(appModuleId)
+ self.send_deleteApplicationModule(authzToken, appModuleId)
return self.recv_deleteApplicationModule()
- def send_deleteApplicationModule(self, appModuleId):
+ def send_deleteApplicationModule(self, authzToken, appModuleId):
self._oprot.writeMessageBegin('deleteApplicationModule', TMessageType.CALL, self._seqid)
args = deleteApplicationModule_args()
+ args.authzToken = authzToken
args.appModuleId = appModuleId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -4933,9 +5182,11 @@ class Client(Iface):
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, "deleteApplicationModule failed: unknown result");
- def registerApplicationDeployment(self, gatewayId, applicationDeployment):
+ def registerApplicationDeployment(self, authzToken, gatewayId, applicationDeployment):
"""
Register a Application Deployment.
@@ -4947,15 +5198,17 @@ class Client(Iface):
Parameters:
+ - authzToken
- gatewayId
- applicationDeployment
"""
- self.send_registerApplicationDeployment(gatewayId, applicationDeployment)
+ self.send_registerApplicationDeployment(authzToken, gatewayId, applicationDeployment)
return self.recv_registerApplicationDeployment()
- def send_registerApplicationDeployment(self, gatewayId, applicationDeployment):
+ def send_registerApplicationDeployment(self, authzToken, gatewayId, applicationDeployment):
self._oprot.writeMessageBegin('registerApplicationDeployment', TMessageType.CALL, self._seqid)
args = registerApplicationDeployment_args()
+ args.authzToken = authzToken
args.gatewayId = gatewayId
args.applicationDeployment = applicationDeployment
args.write(self._oprot)
@@ -4981,9 +5234,11 @@ class Client(Iface):
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, "registerApplicationDeployment failed: unknown result");
- def getApplicationDeployment(self, appDeploymentId):
+ def getApplicationDeployment(self, authzToken, appDeploymentId):
"""
Fetch a Application Deployment.
@@ -4995,14 +5250,16 @@ class Client(Iface):
Parameters:
+ - authzToken
- appDeploymentId
"""
- self.send_getApplicationDeployment(appDeploymentId)
+ self.send_getApplicationDeployment(authzToken, appDeploymentId)
return self.recv_getApplicationDeployment()
- def send_getApplicationDeployment(self, appDeploymentId):
+ def send_getApplicationDeployment(self, authzToken, appDeploymentId):
self._oprot.writeMessageBegin('getApplicationDeployment', TMessageType.CALL, self._seqid)
args = getApplicationDeployment_args()
+ args.authzToken = authzToken
args.appDeploymentId = appDeploymentId
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -5027,9 +5284,11 @@ class Client(Iface):
<TRUNCATED>