airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject [25/31] airavata git commit: updating local to upstream develop
Date Fri, 07 Oct 2016 20:52:52 GMT
http://git-wip-us.apache.org/repos/asf/airavata/blob/fa5a1e0f/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
----------------------------------------------------------------------
diff --cc airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
index 57d4b46,2aef262..fda9c8e
--- 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
@@@ -11342,670 -10846,766 +11345,862 @@@ class Client(Iface)
        raise result.ase
      if result.ae is not None:
        raise result.ae
 -    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGroupsUserBelongs failed: unknown result")
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getDataProduct failed: unknown result")
 +
++<<<<<<< HEAD
 +  def registerReplicaLocation(self, authzToken, replicaLocationModel):
 +    """
 +    Parameters:
 +     - authzToken
 +     - replicaLocationModel
 +    """
 +    self.send_registerReplicaLocation(authzToken, replicaLocationModel)
 +    return self.recv_registerReplicaLocation()
  
 +  def send_registerReplicaLocation(self, authzToken, replicaLocationModel):
 +    self._oprot.writeMessageBegin('registerReplicaLocation', TMessageType.CALL, self._seqid)
 +    args = registerReplicaLocation_args()
 +    args.authzToken = authzToken
 +    args.replicaLocationModel = replicaLocationModel
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
++=======
+   def isDataSharingEnabled(self):
+     self.send_isDataSharingEnabled()
+     return self.recv_isDataSharingEnabled()
+ 
+   def send_isDataSharingEnabled(self):
+     self._oprot.writeMessageBegin('isDataSharingEnabled', TMessageType.CALL, self._seqid)
+     args = isDataSharingEnabled_args()
+     args.write(self._oprot)
+     self._oprot.writeMessageEnd()
+     self._oprot.trans.flush()
+ 
+   def recv_isDataSharingEnabled(self):
+     iprot = self._iprot
+     (fname, mtype, rseqid) = iprot.readMessageBegin()
+     if mtype == TMessageType.EXCEPTION:
+       x = TApplicationException()
+       x.read(iprot)
+       iprot.readMessageEnd()
+       raise x
+     result = isDataSharingEnabled_result()
+     result.read(iprot)
+     iprot.readMessageEnd()
+     if result.success is not None:
+       return result.success
+     if result.ire is not None:
+       raise result.ire
+     if result.ace is not None:
+       raise result.ace
+     if result.ase is not None:
+       raise result.ase
+     if result.ae is not None:
+       raise result.ae
+     raise TApplicationException(TApplicationException.MISSING_RESULT, "isDataSharingEnabled failed: unknown result")
+ 
+ 
+ class Processor(Iface, TProcessor):
+   def __init__(self, handler):
+     self._handler = handler
+     self._processMap = {}
+     self._processMap["getAPIVersion"] = Processor.process_getAPIVersion
+     self._processMap["isUserExists"] = Processor.process_isUserExists
+     self._processMap["addGateway"] = Processor.process_addGateway
+     self._processMap["getAllUsersInGateway"] = Processor.process_getAllUsersInGateway
+     self._processMap["updateGateway"] = Processor.process_updateGateway
+     self._processMap["getGateway"] = Processor.process_getGateway
+     self._processMap["deleteGateway"] = Processor.process_deleteGateway
+     self._processMap["getAllGateways"] = Processor.process_getAllGateways
+     self._processMap["isGatewayExist"] = Processor.process_isGatewayExist
+     self._processMap["createNotification"] = Processor.process_createNotification
+     self._processMap["updateNotification"] = Processor.process_updateNotification
+     self._processMap["deleteNotification"] = Processor.process_deleteNotification
+     self._processMap["getNotification"] = Processor.process_getNotification
+     self._processMap["getAllNotifications"] = Processor.process_getAllNotifications
+     self._processMap["generateAndRegisterSSHKeys"] = Processor.process_generateAndRegisterSSHKeys
+     self._processMap["registerPwdCredential"] = Processor.process_registerPwdCredential
+     self._processMap["getSSHPubKey"] = Processor.process_getSSHPubKey
+     self._processMap["getAllGatewaySSHPubKeys"] = Processor.process_getAllGatewaySSHPubKeys
+     self._processMap["getAllGatewayPWDCredentials"] = Processor.process_getAllGatewayPWDCredentials
+     self._processMap["deleteSSHPubKey"] = Processor.process_deleteSSHPubKey
+     self._processMap["deletePWDCredential"] = Processor.process_deletePWDCredential
+     self._processMap["createProject"] = Processor.process_createProject
+     self._processMap["updateProject"] = Processor.process_updateProject
+     self._processMap["getProject"] = Processor.process_getProject
+     self._processMap["deleteProject"] = Processor.process_deleteProject
+     self._processMap["getUserProjects"] = Processor.process_getUserProjects
+     self._processMap["searchProjects"] = Processor.process_searchProjects
+     self._processMap["searchExperiments"] = Processor.process_searchExperiments
+     self._processMap["getExperimentStatistics"] = Processor.process_getExperimentStatistics
+     self._processMap["getExperimentsInProject"] = Processor.process_getExperimentsInProject
+     self._processMap["getUserExperiments"] = Processor.process_getUserExperiments
+     self._processMap["createExperiment"] = Processor.process_createExperiment
+     self._processMap["deleteExperiment"] = Processor.process_deleteExperiment
+     self._processMap["getExperiment"] = Processor.process_getExperiment
+     self._processMap["getDetailedExperimentTree"] = Processor.process_getDetailedExperimentTree
+     self._processMap["updateExperiment"] = Processor.process_updateExperiment
+     self._processMap["updateExperimentConfiguration"] = Processor.process_updateExperimentConfiguration
+     self._processMap["updateResourceScheduleing"] = Processor.process_updateResourceScheduleing
+     self._processMap["validateExperiment"] = Processor.process_validateExperiment
+     self._processMap["launchExperiment"] = Processor.process_launchExperiment
+     self._processMap["getExperimentStatus"] = Processor.process_getExperimentStatus
+     self._processMap["getExperimentOutputs"] = Processor.process_getExperimentOutputs
+     self._processMap["getIntermediateOutputs"] = Processor.process_getIntermediateOutputs
+     self._processMap["getJobStatuses"] = Processor.process_getJobStatuses
+     self._processMap["getJobDetails"] = Processor.process_getJobDetails
+     self._processMap["cloneExperiment"] = Processor.process_cloneExperiment
+     self._processMap["terminateExperiment"] = Processor.process_terminateExperiment
+     self._processMap["registerApplicationModule"] = Processor.process_registerApplicationModule
+     self._processMap["getApplicationModule"] = Processor.process_getApplicationModule
+     self._processMap["updateApplicationModule"] = Processor.process_updateApplicationModule
+     self._processMap["getAllAppModules"] = Processor.process_getAllAppModules
+     self._processMap["deleteApplicationModule"] = Processor.process_deleteApplicationModule
+     self._processMap["registerApplicationDeployment"] = Processor.process_registerApplicationDeployment
+     self._processMap["getApplicationDeployment"] = Processor.process_getApplicationDeployment
+     self._processMap["updateApplicationDeployment"] = Processor.process_updateApplicationDeployment
+     self._processMap["deleteApplicationDeployment"] = Processor.process_deleteApplicationDeployment
+     self._processMap["getAllApplicationDeployments"] = Processor.process_getAllApplicationDeployments
+     self._processMap["getAppModuleDeployedResources"] = Processor.process_getAppModuleDeployedResources
+     self._processMap["registerApplicationInterface"] = Processor.process_registerApplicationInterface
+     self._processMap["cloneApplicationInterface"] = Processor.process_cloneApplicationInterface
+     self._processMap["getApplicationInterface"] = Processor.process_getApplicationInterface
+     self._processMap["updateApplicationInterface"] = Processor.process_updateApplicationInterface
+     self._processMap["deleteApplicationInterface"] = Processor.process_deleteApplicationInterface
+     self._processMap["getAllApplicationInterfaceNames"] = Processor.process_getAllApplicationInterfaceNames
+     self._processMap["getAllApplicationInterfaces"] = Processor.process_getAllApplicationInterfaces
+     self._processMap["getApplicationInputs"] = Processor.process_getApplicationInputs
+     self._processMap["getApplicationOutputs"] = Processor.process_getApplicationOutputs
+     self._processMap["getAvailableAppInterfaceComputeResources"] = Processor.process_getAvailableAppInterfaceComputeResources
+     self._processMap["registerComputeResource"] = Processor.process_registerComputeResource
+     self._processMap["getComputeResource"] = Processor.process_getComputeResource
+     self._processMap["getAllComputeResourceNames"] = Processor.process_getAllComputeResourceNames
+     self._processMap["updateComputeResource"] = Processor.process_updateComputeResource
+     self._processMap["deleteComputeResource"] = Processor.process_deleteComputeResource
+     self._processMap["registerStorageResource"] = Processor.process_registerStorageResource
+     self._processMap["getStorageResource"] = Processor.process_getStorageResource
+     self._processMap["getAllStorageResourceNames"] = Processor.process_getAllStorageResourceNames
+     self._processMap["updateStorageResource"] = Processor.process_updateStorageResource
+     self._processMap["deleteStorageResource"] = Processor.process_deleteStorageResource
+     self._processMap["addLocalSubmissionDetails"] = Processor.process_addLocalSubmissionDetails
+     self._processMap["updateLocalSubmissionDetails"] = Processor.process_updateLocalSubmissionDetails
+     self._processMap["getLocalJobSubmission"] = Processor.process_getLocalJobSubmission
+     self._processMap["addSSHJobSubmissionDetails"] = Processor.process_addSSHJobSubmissionDetails
+     self._processMap["addSSHForkJobSubmissionDetails"] = Processor.process_addSSHForkJobSubmissionDetails
+     self._processMap["getSSHJobSubmission"] = Processor.process_getSSHJobSubmission
+     self._processMap["addUNICOREJobSubmissionDetails"] = Processor.process_addUNICOREJobSubmissionDetails
+     self._processMap["getUnicoreJobSubmission"] = Processor.process_getUnicoreJobSubmission
+     self._processMap["addCloudJobSubmissionDetails"] = Processor.process_addCloudJobSubmissionDetails
+     self._processMap["getCloudJobSubmission"] = Processor.process_getCloudJobSubmission
+     self._processMap["updateSSHJobSubmissionDetails"] = Processor.process_updateSSHJobSubmissionDetails
+     self._processMap["updateCloudJobSubmissionDetails"] = Processor.process_updateCloudJobSubmissionDetails
+     self._processMap["updateUnicoreJobSubmissionDetails"] = Processor.process_updateUnicoreJobSubmissionDetails
+     self._processMap["addLocalDataMovementDetails"] = Processor.process_addLocalDataMovementDetails
+     self._processMap["updateLocalDataMovementDetails"] = Processor.process_updateLocalDataMovementDetails
+     self._processMap["getLocalDataMovement"] = Processor.process_getLocalDataMovement
+     self._processMap["addSCPDataMovementDetails"] = Processor.process_addSCPDataMovementDetails
+     self._processMap["updateSCPDataMovementDetails"] = Processor.process_updateSCPDataMovementDetails
+     self._processMap["getSCPDataMovement"] = Processor.process_getSCPDataMovement
+     self._processMap["addUnicoreDataMovementDetails"] = Processor.process_addUnicoreDataMovementDetails
+     self._processMap["updateUnicoreDataMovementDetails"] = Processor.process_updateUnicoreDataMovementDetails
+     self._processMap["getUnicoreDataMovement"] = Processor.process_getUnicoreDataMovement
+     self._processMap["addGridFTPDataMovementDetails"] = Processor.process_addGridFTPDataMovementDetails
+     self._processMap["updateGridFTPDataMovementDetails"] = Processor.process_updateGridFTPDataMovementDetails
+     self._processMap["getGridFTPDataMovement"] = Processor.process_getGridFTPDataMovement
+     self._processMap["changeJobSubmissionPriority"] = Processor.process_changeJobSubmissionPriority
+     self._processMap["changeDataMovementPriority"] = Processor.process_changeDataMovementPriority
+     self._processMap["changeJobSubmissionPriorities"] = Processor.process_changeJobSubmissionPriorities
+     self._processMap["changeDataMovementPriorities"] = Processor.process_changeDataMovementPriorities
+     self._processMap["deleteJobSubmissionInterface"] = Processor.process_deleteJobSubmissionInterface
+     self._processMap["deleteDataMovementInterface"] = Processor.process_deleteDataMovementInterface
+     self._processMap["registerResourceJobManager"] = Processor.process_registerResourceJobManager
+     self._processMap["updateResourceJobManager"] = Processor.process_updateResourceJobManager
+     self._processMap["getResourceJobManager"] = Processor.process_getResourceJobManager
+     self._processMap["deleteResourceJobManager"] = Processor.process_deleteResourceJobManager
+     self._processMap["deleteBatchQueue"] = Processor.process_deleteBatchQueue
+     self._processMap["registerGatewayResourceProfile"] = Processor.process_registerGatewayResourceProfile
+     self._processMap["getGatewayResourceProfile"] = Processor.process_getGatewayResourceProfile
+     self._processMap["updateGatewayResourceProfile"] = Processor.process_updateGatewayResourceProfile
+     self._processMap["deleteGatewayResourceProfile"] = Processor.process_deleteGatewayResourceProfile
+     self._processMap["addGatewayComputeResourcePreference"] = Processor.process_addGatewayComputeResourcePreference
+     self._processMap["addGatewayStoragePreference"] = Processor.process_addGatewayStoragePreference
+     self._processMap["getGatewayComputeResourcePreference"] = Processor.process_getGatewayComputeResourcePreference
+     self._processMap["getGatewayStoragePreference"] = Processor.process_getGatewayStoragePreference
+     self._processMap["getAllGatewayComputeResourcePreferences"] = Processor.process_getAllGatewayComputeResourcePreferences
+     self._processMap["getAllGatewayStoragePreferences"] = Processor.process_getAllGatewayStoragePreferences
+     self._processMap["getAllGatewayResourceProfiles"] = Processor.process_getAllGatewayResourceProfiles
+     self._processMap["updateGatewayComputeResourcePreference"] = Processor.process_updateGatewayComputeResourcePreference
+     self._processMap["updateGatewayStoragePreference"] = Processor.process_updateGatewayStoragePreference
+     self._processMap["deleteGatewayComputeResourcePreference"] = Processor.process_deleteGatewayComputeResourcePreference
+     self._processMap["deleteGatewayStoragePreference"] = Processor.process_deleteGatewayStoragePreference
+     self._processMap["getAllWorkflows"] = Processor.process_getAllWorkflows
+     self._processMap["getWorkflow"] = Processor.process_getWorkflow
+     self._processMap["deleteWorkflow"] = Processor.process_deleteWorkflow
+     self._processMap["registerWorkflow"] = Processor.process_registerWorkflow
+     self._processMap["updateWorkflow"] = Processor.process_updateWorkflow
+     self._processMap["getWorkflowTemplateId"] = Processor.process_getWorkflowTemplateId
+     self._processMap["isWorkflowExistWithName"] = Processor.process_isWorkflowExistWithName
+     self._processMap["registerDataProduct"] = Processor.process_registerDataProduct
+     self._processMap["getDataProduct"] = Processor.process_getDataProduct
+     self._processMap["registerReplicaLocation"] = Processor.process_registerReplicaLocation
+     self._processMap["getParentDataProduct"] = Processor.process_getParentDataProduct
+     self._processMap["getChildDataProducts"] = Processor.process_getChildDataProducts
+     self._processMap["shareResourceWithUsers"] = Processor.process_shareResourceWithUsers
+     self._processMap["revokeSharingOfResourceFromUsers"] = Processor.process_revokeSharingOfResourceFromUsers
+     self._processMap["getAllAccessibleUsers"] = Processor.process_getAllAccessibleUsers
+     self._processMap["createGroup"] = Processor.process_createGroup
+     self._processMap["updateGroup"] = Processor.process_updateGroup
+     self._processMap["deleteGroup"] = Processor.process_deleteGroup
+     self._processMap["getGroup"] = Processor.process_getGroup
+     self._processMap["getAllGroupsUserBelongs"] = Processor.process_getAllGroupsUserBelongs
+     self._processMap["isDataSharingEnabled"] = Processor.process_isDataSharingEnabled
++>>>>>>> upstream/develop
  
 -  def process(self, iprot, oprot):
 -    (name, type, seqid) = iprot.readMessageBegin()
 -    if name not in self._processMap:
 -      iprot.skip(TType.STRUCT)
 +  def recv_registerReplicaLocation(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
        iprot.readMessageEnd()
 -      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
 -      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
 -      x.write(oprot)
 -      oprot.writeMessageEnd()
 -      oprot.trans.flush()
 -      return
 -    else:
 -      self._processMap[name](self, seqid, iprot, oprot)
 -    return True
 -
 -  def process_getAPIVersion(self, seqid, iprot, oprot):
 -    args = getAPIVersion_args()
 -    args.read(iprot)
 +      raise x
 +    result = registerReplicaLocation_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = getAPIVersion_result()
 -    try:
 -      result.success = self._handler.getAPIVersion(args.authzToken)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAPIVersion", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "registerReplicaLocation failed: unknown result")
  
 -  def process_isUserExists(self, seqid, iprot, oprot):
 -    args = isUserExists_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = isUserExists_result()
 -    try:
 -      result.success = self._handler.isUserExists(args.authzToken, args.gatewayId, args.userName)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("isUserExists", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def getParentDataProduct(self, authzToken, productUri):
 +    """
 +    Parameters:
 +     - authzToken
 +     - productUri
 +    """
 +    self.send_getParentDataProduct(authzToken, productUri)
 +    return self.recv_getParentDataProduct()
  
 -  def process_addGateway(self, seqid, iprot, oprot):
 -    args = addGateway_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = addGateway_result()
 -    try:
 -      result.success = self._handler.addGateway(args.authzToken, args.gateway)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("addGateway", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def send_getParentDataProduct(self, authzToken, productUri):
 +    self._oprot.writeMessageBegin('getParentDataProduct', TMessageType.CALL, self._seqid)
 +    args = getParentDataProduct_args()
 +    args.authzToken = authzToken
 +    args.productUri = productUri
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
  
 -  def process_getAllUsersInGateway(self, seqid, iprot, oprot):
 -    args = getAllUsersInGateway_args()
 -    args.read(iprot)
 +  def recv_getParentDataProduct(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = getParentDataProduct_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = getAllUsersInGateway_result()
 -    try:
 -      result.success = self._handler.getAllUsersInGateway(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAllUsersInGateway", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getParentDataProduct failed: unknown result")
  
 -  def process_updateGateway(self, seqid, iprot, oprot):
 -    args = updateGateway_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = updateGateway_result()
 -    try:
 -      result.success = self._handler.updateGateway(args.authzToken, args.gatewayId, args.updatedGateway)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("updateGateway", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def getChildDataProducts(self, authzToken, productUri):
 +    """
 +    Parameters:
 +     - authzToken
 +     - productUri
 +    """
 +    self.send_getChildDataProducts(authzToken, productUri)
 +    return self.recv_getChildDataProducts()
  
 -  def process_getGateway(self, seqid, iprot, oprot):
 -    args = getGateway_args()
 -    args.read(iprot)
 +  def send_getChildDataProducts(self, authzToken, productUri):
 +    self._oprot.writeMessageBegin('getChildDataProducts', TMessageType.CALL, self._seqid)
 +    args = getChildDataProducts_args()
 +    args.authzToken = authzToken
 +    args.productUri = productUri
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_getChildDataProducts(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = getChildDataProducts_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = getGateway_result()
 -    try:
 -      result.success = self._handler.getGateway(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getGateway", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getChildDataProducts failed: unknown result")
  
 -  def process_deleteGateway(self, seqid, iprot, oprot):
 -    args = deleteGateway_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = deleteGateway_result()
 -    try:
 -      result.success = self._handler.deleteGateway(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("deleteGateway", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def shareResourceWithUsers(self, authzToken, resourceId, resourceType, userPermissionList):
 +    """
 +    Group Manager and Data Sharing Related API methods
  
 -  def process_getAllGateways(self, seqid, iprot, oprot):
 -    args = getAllGateways_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = getAllGateways_result()
 -    try:
 -      result.success = self._handler.getAllGateways(args.authzToken)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAllGateways", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
  
 -  def process_isGatewayExist(self, seqid, iprot, oprot):
 -    args = isGatewayExist_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = isGatewayExist_result()
 -    try:
 -      result.success = self._handler.isGatewayExist(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("isGatewayExist", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    Parameters:
 +     - authzToken
 +     - resourceId
 +     - resourceType
 +     - userPermissionList
 +    """
 +    self.send_shareResourceWithUsers(authzToken, resourceId, resourceType, userPermissionList)
 +    return self.recv_shareResourceWithUsers()
  
 -  def process_createNotification(self, seqid, iprot, oprot):
 -    args = createNotification_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = createNotification_result()
 -    try:
 -      result.success = self._handler.createNotification(args.authzToken, args.notification)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("createNotification", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def send_shareResourceWithUsers(self, authzToken, resourceId, resourceType, userPermissionList):
 +    self._oprot.writeMessageBegin('shareResourceWithUsers', TMessageType.CALL, self._seqid)
 +    args = shareResourceWithUsers_args()
 +    args.authzToken = authzToken
 +    args.resourceId = resourceId
 +    args.resourceType = resourceType
 +    args.userPermissionList = userPermissionList
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
  
 -  def process_updateNotification(self, seqid, iprot, oprot):
 -    args = updateNotification_args()
 -    args.read(iprot)
 +  def recv_shareResourceWithUsers(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = shareResourceWithUsers_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = updateNotification_result()
 -    try:
 -      result.success = self._handler.updateNotification(args.authzToken, args.notification)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("updateNotification", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "shareResourceWithUsers failed: unknown result")
  
 -  def process_deleteNotification(self, seqid, iprot, oprot):
 -    args = deleteNotification_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = deleteNotification_result()
 -    try:
 -      result.success = self._handler.deleteNotification(args.authzToken, args.gatewayId, args.notificationId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("deleteNotification", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def revokeSharingOfResourceFromUsers(self, authzToken, resourceId, resourceType, userPermissionList):
 +    """
 +    Parameters:
 +     - authzToken
 +     - resourceId
 +     - resourceType
 +     - userPermissionList
 +    """
 +    self.send_revokeSharingOfResourceFromUsers(authzToken, resourceId, resourceType, userPermissionList)
 +    return self.recv_revokeSharingOfResourceFromUsers()
  
 -  def process_getNotification(self, seqid, iprot, oprot):
 -    args = getNotification_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = getNotification_result()
 -    try:
 -      result.success = self._handler.getNotification(args.authzToken, args.gatewayId, args.notificationId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getNotification", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def send_revokeSharingOfResourceFromUsers(self, authzToken, resourceId, resourceType, userPermissionList):
 +    self._oprot.writeMessageBegin('revokeSharingOfResourceFromUsers', TMessageType.CALL, self._seqid)
 +    args = revokeSharingOfResourceFromUsers_args()
 +    args.authzToken = authzToken
 +    args.resourceId = resourceId
 +    args.resourceType = resourceType
 +    args.userPermissionList = userPermissionList
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
  
 -  def process_getAllNotifications(self, seqid, iprot, oprot):
 -    args = getAllNotifications_args()
 -    args.read(iprot)
 +  def recv_revokeSharingOfResourceFromUsers(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = revokeSharingOfResourceFromUsers_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = getAllNotifications_result()
 -    try:
 -      result.success = self._handler.getAllNotifications(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAllNotifications", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "revokeSharingOfResourceFromUsers failed: unknown result")
  
 -  def process_generateAndRegisterSSHKeys(self, seqid, iprot, oprot):
 -    args = generateAndRegisterSSHKeys_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = generateAndRegisterSSHKeys_result()
 -    try:
 -      result.success = self._handler.generateAndRegisterSSHKeys(args.authzToken, args.gatewayId, args.userName)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("generateAndRegisterSSHKeys", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def getAllAccessibleUsers(self, authzToken, resourceId, resourceType, permissionType):
 +    """
 +    Parameters:
 +     - authzToken
 +     - resourceId
 +     - resourceType
 +     - permissionType
 +    """
 +    self.send_getAllAccessibleUsers(authzToken, resourceId, resourceType, permissionType)
 +    return self.recv_getAllAccessibleUsers()
  
 -  def process_registerPwdCredential(self, seqid, iprot, oprot):
 -    args = registerPwdCredential_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = registerPwdCredential_result()
 -    try:
 -      result.success = self._handler.registerPwdCredential(args.authzToken, args.gatewayId, args.portalUserName, args.loginUserName, args.password, args.description)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("registerPwdCredential", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def send_getAllAccessibleUsers(self, authzToken, resourceId, resourceType, permissionType):
 +    self._oprot.writeMessageBegin('getAllAccessibleUsers', TMessageType.CALL, self._seqid)
 +    args = getAllAccessibleUsers_args()
 +    args.authzToken = authzToken
 +    args.resourceId = resourceId
 +    args.resourceType = resourceType
 +    args.permissionType = permissionType
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
  
 -  def process_getSSHPubKey(self, seqid, iprot, oprot):
 -    args = getSSHPubKey_args()
 -    args.read(iprot)
 +  def recv_getAllAccessibleUsers(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = getAllAccessibleUsers_result()
 +    result.read(iprot)
      iprot.readMessageEnd()
 -    result = getSSHPubKey_result()
 -    try:
 -      result.success = self._handler.getSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getSSHPubKey", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllAccessibleUsers failed: unknown result")
  
 -  def process_getAllGatewaySSHPubKeys(self, seqid, iprot, oprot):
 -    args = getAllGatewaySSHPubKeys_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = getAllGatewaySSHPubKeys_result()
 -    try:
 -      result.success = self._handler.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAllGatewaySSHPubKeys", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def createGroup(self, authzToken, groupModel):
 +    """
 +    Parameters:
 +     - authzToken
 +     - groupModel
 +    """
 +    self.send_createGroup(authzToken, groupModel)
 +    return self.recv_createGroup()
  
 -  def process_getAllGatewayPWDCredentials(self, seqid, iprot, oprot):
 -    args = getAllGatewayPWDCredentials_args()
 +  def send_createGroup(self, authzToken, groupModel):
 +    self._oprot.writeMessageBegin('createGroup', TMessageType.CALL, self._seqid)
 +    args = createGroup_args()
 +    args.authzToken = authzToken
 +    args.groupModel = groupModel
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_createGroup(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = createGroup_result()
 +    result.read(iprot)
 +    iprot.readMessageEnd()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "createGroup failed: unknown result")
 +
 +  def updateGroup(self, authzToken, groupModel):
 +    """
 +    Parameters:
 +     - authzToken
 +     - groupModel
 +    """
 +    self.send_updateGroup(authzToken, groupModel)
 +    return self.recv_updateGroup()
 +
 +  def send_updateGroup(self, authzToken, groupModel):
 +    self._oprot.writeMessageBegin('updateGroup', TMessageType.CALL, self._seqid)
 +    args = updateGroup_args()
 +    args.authzToken = authzToken
 +    args.groupModel = groupModel
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_updateGroup(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = updateGroup_result()
 +    result.read(iprot)
 +    iprot.readMessageEnd()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGroup failed: unknown result")
 +
 +  def deleteGroup(self, authzToken, groupId, ownerId, gatewayId):
 +    """
 +    Parameters:
 +     - authzToken
 +     - groupId
 +     - ownerId
 +     - gatewayId
 +    """
 +    self.send_deleteGroup(authzToken, groupId, ownerId, gatewayId)
 +    return self.recv_deleteGroup()
 +
 +  def send_deleteGroup(self, authzToken, groupId, ownerId, gatewayId):
 +    self._oprot.writeMessageBegin('deleteGroup', TMessageType.CALL, self._seqid)
 +    args = deleteGroup_args()
 +    args.authzToken = authzToken
 +    args.groupId = groupId
 +    args.ownerId = ownerId
 +    args.gatewayId = gatewayId
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_deleteGroup(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = deleteGroup_result()
 +    result.read(iprot)
 +    iprot.readMessageEnd()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGroup failed: unknown result")
 +
 +  def getGroup(self, authzToken, groupId):
 +    """
 +    Parameters:
 +     - authzToken
 +     - groupId
 +    """
 +    self.send_getGroup(authzToken, groupId)
 +    return self.recv_getGroup()
 +
 +  def send_getGroup(self, authzToken, groupId):
 +    self._oprot.writeMessageBegin('getGroup', TMessageType.CALL, self._seqid)
 +    args = getGroup_args()
 +    args.authzToken = authzToken
 +    args.groupId = groupId
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_getGroup(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = getGroup_result()
 +    result.read(iprot)
 +    iprot.readMessageEnd()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getGroup failed: unknown result")
 +
 +  def getAllGroupsUserBelongs(self, authzToken, userName, gatewayId):
 +    """
 +    Parameters:
 +     - authzToken
 +     - userName
 +     - gatewayId
 +    """
 +    self.send_getAllGroupsUserBelongs(authzToken, userName, gatewayId)
 +    return self.recv_getAllGroupsUserBelongs()
 +
 +  def send_getAllGroupsUserBelongs(self, authzToken, userName, gatewayId):
 +    self._oprot.writeMessageBegin('getAllGroupsUserBelongs', TMessageType.CALL, self._seqid)
 +    args = getAllGroupsUserBelongs_args()
 +    args.authzToken = authzToken
 +    args.userName = userName
 +    args.gatewayId = gatewayId
 +    args.write(self._oprot)
 +    self._oprot.writeMessageEnd()
 +    self._oprot.trans.flush()
 +
 +  def recv_getAllGroupsUserBelongs(self):
 +    iprot = self._iprot
 +    (fname, mtype, rseqid) = iprot.readMessageBegin()
 +    if mtype == TMessageType.EXCEPTION:
 +      x = TApplicationException()
 +      x.read(iprot)
 +      iprot.readMessageEnd()
 +      raise x
 +    result = getAllGroupsUserBelongs_result()
 +    result.read(iprot)
 +    iprot.readMessageEnd()
 +    if result.success is not None:
 +      return result.success
 +    if result.ire is not None:
 +      raise result.ire
 +    if result.ace is not None:
 +      raise result.ace
 +    if result.ase is not None:
 +      raise result.ase
 +    if result.ae is not None:
 +      raise result.ae
 +    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGroupsUserBelongs failed: unknown result")
 +
 +
 +class Processor(Iface, TProcessor):
 +  def __init__(self, handler):
 +    self._handler = handler
 +    self._processMap = {}
 +    self._processMap["getAPIVersion"] = Processor.process_getAPIVersion
 +    self._processMap["isUserExists"] = Processor.process_isUserExists
 +    self._processMap["addGateway"] = Processor.process_addGateway
 +    self._processMap["getAllUsersInGateway"] = Processor.process_getAllUsersInGateway
 +    self._processMap["updateGateway"] = Processor.process_updateGateway
 +    self._processMap["getGateway"] = Processor.process_getGateway
 +    self._processMap["deleteGateway"] = Processor.process_deleteGateway
 +    self._processMap["getAllGateways"] = Processor.process_getAllGateways
 +    self._processMap["isGatewayExist"] = Processor.process_isGatewayExist
 +    self._processMap["createNotification"] = Processor.process_createNotification
 +    self._processMap["updateNotification"] = Processor.process_updateNotification
 +    self._processMap["deleteNotification"] = Processor.process_deleteNotification
 +    self._processMap["getNotification"] = Processor.process_getNotification
 +    self._processMap["getAllNotifications"] = Processor.process_getAllNotifications
 +    self._processMap["generateAndRegisterSSHKeys"] = Processor.process_generateAndRegisterSSHKeys
 +    self._processMap["registerPwdCredential"] = Processor.process_registerPwdCredential
 +    self._processMap["getSSHPubKey"] = Processor.process_getSSHPubKey
 +    self._processMap["getAllGatewaySSHPubKeys"] = Processor.process_getAllGatewaySSHPubKeys
 +    self._processMap["getAllGatewayPWDCredentials"] = Processor.process_getAllGatewayPWDCredentials
 +    self._processMap["deleteSSHPubKey"] = Processor.process_deleteSSHPubKey
 +    self._processMap["deletePWDCredential"] = Processor.process_deletePWDCredential
 +    self._processMap["createProject"] = Processor.process_createProject
 +    self._processMap["updateProject"] = Processor.process_updateProject
 +    self._processMap["getProject"] = Processor.process_getProject
 +    self._processMap["deleteProject"] = Processor.process_deleteProject
 +    self._processMap["getUserProjects"] = Processor.process_getUserProjects
 +    self._processMap["searchProjects"] = Processor.process_searchProjects
 +    self._processMap["searchExperiments"] = Processor.process_searchExperiments
 +    self._processMap["getExperimentStatistics"] = Processor.process_getExperimentStatistics
 +    self._processMap["getExperimentsInProject"] = Processor.process_getExperimentsInProject
 +    self._processMap["getUserExperiments"] = Processor.process_getUserExperiments
 +    self._processMap["createExperiment"] = Processor.process_createExperiment
 +    self._processMap["deleteExperiment"] = Processor.process_deleteExperiment
 +    self._processMap["getExperiment"] = Processor.process_getExperiment
 +    self._processMap["getDetailedExperimentTree"] = Processor.process_getDetailedExperimentTree
 +    self._processMap["updateExperiment"] = Processor.process_updateExperiment
 +    self._processMap["updateExperimentConfiguration"] = Processor.process_updateExperimentConfiguration
 +    self._processMap["updateResourceScheduleing"] = Processor.process_updateResourceScheduleing
 +    self._processMap["validateExperiment"] = Processor.process_validateExperiment
 +    self._processMap["launchExperiment"] = Processor.process_launchExperiment
 +    self._processMap["getExperimentStatus"] = Processor.process_getExperimentStatus
 +    self._processMap["getExperimentOutputs"] = Processor.process_getExperimentOutputs
 +    self._processMap["getIntermediateOutputs"] = Processor.process_getIntermediateOutputs
 +    self._processMap["getJobStatuses"] = Processor.process_getJobStatuses
 +    self._processMap["getJobDetails"] = Processor.process_getJobDetails
 +    self._processMap["cloneExperiment"] = Processor.process_cloneExperiment
 +    self._processMap["terminateExperiment"] = Processor.process_terminateExperiment
 +    self._processMap["registerApplicationModule"] = Processor.process_registerApplicationModule
 +    self._processMap["getApplicationModule"] = Processor.process_getApplicationModule
 +    self._processMap["updateApplicationModule"] = Processor.process_updateApplicationModule
 +    self._processMap["getAllAppModules"] = Processor.process_getAllAppModules
 +    self._processMap["deleteApplicationModule"] = Processor.process_deleteApplicationModule
 +    self._processMap["registerApplicationDeployment"] = Processor.process_registerApplicationDeployment
 +    self._processMap["getApplicationDeployment"] = Processor.process_getApplicationDeployment
 +    self._processMap["updateApplicationDeployment"] = Processor.process_updateApplicationDeployment
 +    self._processMap["deleteApplicationDeployment"] = Processor.process_deleteApplicationDeployment
 +    self._processMap["getAllApplicationDeployments"] = Processor.process_getAllApplicationDeployments
 +    self._processMap["getAppModuleDeployedResources"] = Processor.process_getAppModuleDeployedResources
 +    self._processMap["registerApplicationInterface"] = Processor.process_registerApplicationInterface
 +    self._processMap["cloneApplicationInterface"] = Processor.process_cloneApplicationInterface
 +    self._processMap["getApplicationInterface"] = Processor.process_getApplicationInterface
 +    self._processMap["updateApplicationInterface"] = Processor.process_updateApplicationInterface
 +    self._processMap["deleteApplicationInterface"] = Processor.process_deleteApplicationInterface
 +    self._processMap["getAllApplicationInterfaceNames"] = Processor.process_getAllApplicationInterfaceNames
 +    self._processMap["getAllApplicationInterfaces"] = Processor.process_getAllApplicationInterfaces
 +    self._processMap["getApplicationInputs"] = Processor.process_getApplicationInputs
 +    self._processMap["getApplicationOutputs"] = Processor.process_getApplicationOutputs
 +    self._processMap["getAvailableAppInterfaceComputeResources"] = Processor.process_getAvailableAppInterfaceComputeResources
 +    self._processMap["registerComputeResource"] = Processor.process_registerComputeResource
 +    self._processMap["getComputeResource"] = Processor.process_getComputeResource
 +    self._processMap["getAllComputeResourceNames"] = Processor.process_getAllComputeResourceNames
 +    self._processMap["updateComputeResource"] = Processor.process_updateComputeResource
 +    self._processMap["deleteComputeResource"] = Processor.process_deleteComputeResource
 +    self._processMap["registerStorageResource"] = Processor.process_registerStorageResource
 +    self._processMap["getStorageResource"] = Processor.process_getStorageResource
 +    self._processMap["getAllStorageResourceNames"] = Processor.process_getAllStorageResourceNames
 +    self._processMap["updateStorageResource"] = Processor.process_updateStorageResource
 +    self._processMap["deleteStorageResource"] = Processor.process_deleteStorageResource
 +    self._processMap["addLocalSubmissionDetails"] = Processor.process_addLocalSubmissionDetails
 +    self._processMap["updateLocalSubmissionDetails"] = Processor.process_updateLocalSubmissionDetails
 +    self._processMap["getLocalJobSubmission"] = Processor.process_getLocalJobSubmission
 +    self._processMap["addSSHJobSubmissionDetails"] = Processor.process_addSSHJobSubmissionDetails
 +    self._processMap["addSSHForkJobSubmissionDetails"] = Processor.process_addSSHForkJobSubmissionDetails
 +    self._processMap["getSSHJobSubmission"] = Processor.process_getSSHJobSubmission
 +    self._processMap["addUNICOREJobSubmissionDetails"] = Processor.process_addUNICOREJobSubmissionDetails
 +    self._processMap["getUnicoreJobSubmission"] = Processor.process_getUnicoreJobSubmission
 +    self._processMap["addCloudJobSubmissionDetails"] = Processor.process_addCloudJobSubmissionDetails
 +    self._processMap["getCloudJobSubmission"] = Processor.process_getCloudJobSubmission
 +    self._processMap["updateSSHJobSubmissionDetails"] = Processor.process_updateSSHJobSubmissionDetails
 +    self._processMap["updateCloudJobSubmissionDetails"] = Processor.process_updateCloudJobSubmissionDetails
 +    self._processMap["updateUnicoreJobSubmissionDetails"] = Processor.process_updateUnicoreJobSubmissionDetails
 +    self._processMap["addLocalDataMovementDetails"] = Processor.process_addLocalDataMovementDetails
 +    self._processMap["updateLocalDataMovementDetails"] = Processor.process_updateLocalDataMovementDetails
 +    self._processMap["getLocalDataMovement"] = Processor.process_getLocalDataMovement
 +    self._processMap["addSCPDataMovementDetails"] = Processor.process_addSCPDataMovementDetails
 +    self._processMap["updateSCPDataMovementDetails"] = Processor.process_updateSCPDataMovementDetails
 +    self._processMap["getSCPDataMovement"] = Processor.process_getSCPDataMovement
 +    self._processMap["addUnicoreDataMovementDetails"] = Processor.process_addUnicoreDataMovementDetails
 +    self._processMap["updateUnicoreDataMovementDetails"] = Processor.process_updateUnicoreDataMovementDetails
 +    self._processMap["getUnicoreDataMovement"] = Processor.process_getUnicoreDataMovement
 +    self._processMap["addGridFTPDataMovementDetails"] = Processor.process_addGridFTPDataMovementDetails
 +    self._processMap["updateGridFTPDataMovementDetails"] = Processor.process_updateGridFTPDataMovementDetails
 +    self._processMap["getGridFTPDataMovement"] = Processor.process_getGridFTPDataMovement
 +    self._processMap["changeJobSubmissionPriority"] = Processor.process_changeJobSubmissionPriority
 +    self._processMap["changeDataMovementPriority"] = Processor.process_changeDataMovementPriority
 +    self._processMap["changeJobSubmissionPriorities"] = Processor.process_changeJobSubmissionPriorities
 +    self._processMap["changeDataMovementPriorities"] = Processor.process_changeDataMovementPriorities
 +    self._processMap["deleteJobSubmissionInterface"] = Processor.process_deleteJobSubmissionInterface
 +    self._processMap["deleteDataMovementInterface"] = Processor.process_deleteDataMovementInterface
 +    self._processMap["registerResourceJobManager"] = Processor.process_registerResourceJobManager
 +    self._processMap["updateResourceJobManager"] = Processor.process_updateResourceJobManager
 +    self._processMap["getResourceJobManager"] = Processor.process_getResourceJobManager
 +    self._processMap["deleteResourceJobManager"] = Processor.process_deleteResourceJobManager
 +    self._processMap["deleteBatchQueue"] = Processor.process_deleteBatchQueue
 +    self._processMap["registerGatewayResourceProfile"] = Processor.process_registerGatewayResourceProfile
 +    self._processMap["getGatewayResourceProfile"] = Processor.process_getGatewayResourceProfile
 +    self._processMap["updateGatewayResourceProfile"] = Processor.process_updateGatewayResourceProfile
 +    self._processMap["deleteGatewayResourceProfile"] = Processor.process_deleteGatewayResourceProfile
 +    self._processMap["addGatewayComputeResourcePreference"] = Processor.process_addGatewayComputeResourcePreference
 +    self._processMap["addGatewayStoragePreference"] = Processor.process_addGatewayStoragePreference
 +    self._processMap["getGatewayComputeResourcePreference"] = Processor.process_getGatewayComputeResourcePreference
 +    self._processMap["getGatewayStoragePreference"] = Processor.process_getGatewayStoragePreference
 +    self._processMap["getAllGatewayComputeResourcePreferences"] = Processor.process_getAllGatewayComputeResourcePreferences
 +    self._processMap["getAllGatewayStoragePreferences"] = Processor.process_getAllGatewayStoragePreferences
 +    self._processMap["getAllGatewayResourceProfiles"] = Processor.process_getAllGatewayResourceProfiles
 +    self._processMap["updateGatewayComputeResourcePreference"] = Processor.process_updateGatewayComputeResourcePreference
 +    self._processMap["updateGatewayStoragePreference"] = Processor.process_updateGatewayStoragePreference
 +    self._processMap["deleteGatewayComputeResourcePreference"] = Processor.process_deleteGatewayComputeResourcePreference
 +    self._processMap["deleteGatewayStoragePreference"] = Processor.process_deleteGatewayStoragePreference
 +    self._processMap["registerUserResourceProfile"] = Processor.process_registerUserResourceProfile
 +    self._processMap["getUserResourceProfile"] = Processor.process_getUserResourceProfile
 +    self._processMap["updateUserResourceProfile"] = Processor.process_updateUserResourceProfile
 +    self._processMap["deleteUserResourceProfile"] = Processor.process_deleteUserResourceProfile
 +    self._processMap["addUserComputeResourcePreference"] = Processor.process_addUserComputeResourcePreference
 +    self._processMap["addUserStoragePreference"] = Processor.process_addUserStoragePreference
 +    self._processMap["getUserComputeResourcePreference"] = Processor.process_getUserComputeResourcePreference
 +    self._processMap["getUserStoragePreference"] = Processor.process_getUserStoragePreference
 +    self._processMap["getAllUserResourceProfiles"] = Processor.process_getAllUserResourceProfiles
 +    self._processMap["updateUserComputeResourcePreference"] = Processor.process_updateUserComputeResourcePreference
 +    self._processMap["updateUserStoragePreference"] = Processor.process_updateUserStoragePreference
 +    self._processMap["deleteUserComputeResourcePreference"] = Processor.process_deleteUserComputeResourcePreference
 +    self._processMap["deleteUserStoragePreference"] = Processor.process_deleteUserStoragePreference
 +    self._processMap["getAllWorkflows"] = Processor.process_getAllWorkflows
 +    self._processMap["getWorkflow"] = Processor.process_getWorkflow
 +    self._processMap["deleteWorkflow"] = Processor.process_deleteWorkflow
 +    self._processMap["registerWorkflow"] = Processor.process_registerWorkflow
 +    self._processMap["updateWorkflow"] = Processor.process_updateWorkflow
 +    self._processMap["getWorkflowTemplateId"] = Processor.process_getWorkflowTemplateId
 +    self._processMap["isWorkflowExistWithName"] = Processor.process_isWorkflowExistWithName
 +    self._processMap["registerDataProduct"] = Processor.process_registerDataProduct
 +    self._processMap["getDataProduct"] = Processor.process_getDataProduct
 +    self._processMap["registerReplicaLocation"] = Processor.process_registerReplicaLocation
 +    self._processMap["getParentDataProduct"] = Processor.process_getParentDataProduct
 +    self._processMap["getChildDataProducts"] = Processor.process_getChildDataProducts
 +    self._processMap["shareResourceWithUsers"] = Processor.process_shareResourceWithUsers
 +    self._processMap["revokeSharingOfResourceFromUsers"] = Processor.process_revokeSharingOfResourceFromUsers
 +    self._processMap["getAllAccessibleUsers"] = Processor.process_getAllAccessibleUsers
 +    self._processMap["createGroup"] = Processor.process_createGroup
 +    self._processMap["updateGroup"] = Processor.process_updateGroup
 +    self._processMap["deleteGroup"] = Processor.process_deleteGroup
 +    self._processMap["getGroup"] = Processor.process_getGroup
 +    self._processMap["getAllGroupsUserBelongs"] = Processor.process_getAllGroupsUserBelongs
 +
 +  def process(self, iprot, oprot):
 +    (name, type, seqid) = iprot.readMessageBegin()
 +    if name not in self._processMap:
 +      iprot.skip(TType.STRUCT)
 +      iprot.readMessageEnd()
 +      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
 +      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
 +      x.write(oprot)
 +      oprot.writeMessageEnd()
 +      oprot.trans.flush()
 +      return
 +    else:
 +      self._processMap[name](self, seqid, iprot, oprot)
 +    return True
 +
 +  def process_getAPIVersion(self, seqid, iprot, oprot):
 +    args = getAPIVersion_args()
      args.read(iprot)
      iprot.readMessageEnd()
 -    result = getAllGatewayPWDCredentials_result()
 +    result = getAPIVersion_result()
      try:
 -      result.success = self._handler.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId)
 +      result.success = self._handler.getAPIVersion(args.authzToken)
        msg_type = TMessageType.REPLY
      except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
        raise
@@@ -16162,2725 -15495,227 +16357,2759 @@@
      oprot.writeMessageEnd()
      oprot.trans.flush()
  
 -  def process_getAllAccessibleUsers(self, seqid, iprot, oprot):
 -    args = getAllAccessibleUsers_args()
 -    args.read(iprot)
 -    iprot.readMessageEnd()
 -    result = getAllAccessibleUsers_result()
 -    try:
 -      result.success = self._handler.getAllAccessibleUsers(args.authzToken, args.resourceId, args.resourceType, args.permissionType)
 -      msg_type = TMessageType.REPLY
 -    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 -      raise
 -    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 -      msg_type = TMessageType.REPLY
 -      result.ire = ire
 -    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 -      msg_type = TMessageType.REPLY
 -      result.ace = ace
 -    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 -      msg_type = TMessageType.REPLY
 -      result.ase = ase
 -    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 -      msg_type = TMessageType.REPLY
 -      result.ae = ae
 -    except Exception as ex:
 -      msg_type = TMessageType.EXCEPTION
 -      logging.exception(ex)
 -      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 -    oprot.writeMessageBegin("getAllAccessibleUsers", msg_type, seqid)
 -    result.write(oprot)
 -    oprot.writeMessageEnd()
 -    oprot.trans.flush()
 +  def process_addUserStoragePreference(self, seqid, iprot, oprot):
 +    args = addUserStoragePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = addUserStoragePreference_result()
 +    try:
 +      result.success = self._handler.addUserStoragePreference(args.authzToken, args.userId, args.storageResourceId, args.storagePreference)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("addUserStoragePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_getUserComputeResourcePreference(self, seqid, iprot, oprot):
 +    args = getUserComputeResourcePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = getUserComputeResourcePreference_result()
 +    try:
 +      result.success = self._handler.getUserComputeResourcePreference(args.authzToken, args.userId, args.computeResourceId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("getUserComputeResourcePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_getUserStoragePreference(self, seqid, iprot, oprot):
 +    args = getUserStoragePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = getUserStoragePreference_result()
 +    try:
 +      result.success = self._handler.getUserStoragePreference(args.authzToken, args.userId, args.storageResourceId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("getUserStoragePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_getAllUserResourceProfiles(self, seqid, iprot, oprot):
 +    args = getAllUserResourceProfiles_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = getAllUserResourceProfiles_result()
 +    try:
 +      result.success = self._handler.getAllUserResourceProfiles(args.authzToken)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("getAllUserResourceProfiles", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_updateUserComputeResourcePreference(self, seqid, iprot, oprot):
 +    args = updateUserComputeResourcePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = updateUserComputeResourcePreference_result()
 +    try:
 +      result.success = self._handler.updateUserComputeResourcePreference(args.authzToken, args.userId, args.computeResourceId, args.computeResourcePreference)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("updateUserComputeResourcePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_updateUserStoragePreference(self, seqid, iprot, oprot):
 +    args = updateUserStoragePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = updateUserStoragePreference_result()
 +    try:
 +      result.success = self._handler.updateUserStoragePreference(args.authzToken, args.userId, args.storageId, args.storagePreference)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("updateUserStoragePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_deleteUserComputeResourcePreference(self, seqid, iprot, oprot):
 +    args = deleteUserComputeResourcePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = deleteUserComputeResourcePreference_result()
 +    try:
 +      result.success = self._handler.deleteUserComputeResourcePreference(args.authzToken, args.userId, args.computeResourceId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("deleteUserComputeResourcePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_deleteUserStoragePreference(self, seqid, iprot, oprot):
 +    args = deleteUserStoragePreference_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = deleteUserStoragePreference_result()
 +    try:
 +      result.success = self._handler.deleteUserStoragePreference(args.authzToken, args.userId, args.storageId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("deleteUserStoragePreference", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_getAllWorkflows(self, seqid, iprot, oprot):
 +    args = getAllWorkflows_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = getAllWorkflows_result()
 +    try:
 +      result.success = self._handler.getAllWorkflows(args.authzToken, args.gatewayId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("getAllWorkflows", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_getWorkflow(self, seqid, iprot, oprot):
 +    args = getWorkflow_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = getWorkflow_result()
 +    try:
 +      result.success = self._handler.getWorkflow(args.authzToken, args.workflowTemplateId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
 +    oprot.writeMessageBegin("getWorkflow", msg_type, seqid)
 +    result.write(oprot)
 +    oprot.writeMessageEnd()
 +    oprot.trans.flush()
 +
 +  def process_deleteWorkflow(self, seqid, iprot, oprot):
 +    args = deleteWorkflow_args()
 +    args.read(iprot)
 +    iprot.readMessageEnd()
 +    result = deleteWorkflow_result()
 +    try:
 +      self._handler.deleteWorkflow(args.authzToken, args.workflowTemplateId)
 +      msg_type = TMessageType.REPLY
 +    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
 +      raise
 +    except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
 +      msg_type = TMessageType.REPLY
 +      result.ire = ire
 +    except apache.airavata.api.error.ttypes.AiravataClientException as ace:
 +      msg_type = TMessageType.REPLY
 +      result.ace = ace
 +    except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
 +      msg_type = TMessageType.REPLY
 +      result.ase = ase
 +    except apache.airavata.api.error.ttypes.AuthorizationException as ae:
 +      msg_type = TMessageType.REPLY
 +      result.ae = ae
 +    except Exception as ex:
 +      msg_type = TMessageType.EXCEPTION
 +      logging.exception(ex)
 +      result = TApplicationException(TApplic

<TRUNCATED>

Mime
View raw message