airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sma...@apache.org
Subject [35/44] airavata git commit: fixed all compilation errors in the java client samples after the API changes.
Date Tue, 21 Jul 2015 04:42:18 GMT
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>

Mime
View raw message