You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2018/06/04 18:15:06 UTC
[airavata-django-portal] 04/04: Regenerate Thrift stubs
This is an automated email from the ASF dual-hosted git repository.
machristie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-django-portal.git
commit ad977a5735bcc01adcee450073405aac9365f670
Author: Marcus Christie <ma...@iu.edu>
AuthorDate: Mon Jun 4 14:14:28 2018 -0400
Regenerate Thrift stubs
---
airavata/api/sharing/SharingRegistryService-remote | 8 +-
airavata/api/sharing/SharingRegistryService.py | 144 ++++++++++-----------
airavata/model/group/ttypes.py | 3 -
airavata/model/status/ttypes.py | 56 +++++++-
4 files changed, 128 insertions(+), 83 deletions(-)
diff --git a/airavata/api/sharing/SharingRegistryService-remote b/airavata/api/sharing/SharingRegistryService-remote
index f246f2d..4e45a36 100755
--- a/airavata/api/sharing/SharingRegistryService-remote
+++ b/airavata/api/sharing/SharingRegistryService-remote
@@ -74,10 +74,10 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' bool deletePermissionType(string domainId, string permissionTypeId)')
print(' PermissionType getPermissionType(string domainId, string permissionTypeId)')
print(' getPermissionTypes(string domainId, i32 offset, i32 limit)')
- print(' bool shareEntityWithUsers(string domainId, string entityId, userList, string perssionTypeId, bool cascadePermission)')
- print(' bool revokeEntitySharingFromUsers(string domainId, string entityId, userList, string perssionTypeId)')
- print(' bool shareEntityWithGroups(string domainId, string entityId, groupList, string perssionTypeId, bool cascadePermission)')
- print(' bool revokeEntitySharingFromGroups(string domainId, string entityId, groupList, string perssionTypeId)')
+ print(' bool shareEntityWithUsers(string domainId, string entityId, userList, string permissionTypeId, bool cascadePermission)')
+ print(' bool revokeEntitySharingFromUsers(string domainId, string entityId, userList, string permissionTypeId)')
+ print(' bool shareEntityWithGroups(string domainId, string entityId, groupList, string permissionTypeId, bool cascadePermission)')
+ print(' bool revokeEntitySharingFromGroups(string domainId, string entityId, groupList, string permissionTypeId)')
print(' bool userHasAccess(string domainId, string userId, string entityId, string permissionTypeId)')
print('')
sys.exit(0)
diff --git a/airavata/api/sharing/SharingRegistryService.py b/airavata/api/sharing/SharingRegistryService.py
index 639a4e6..dd3c22f 100644
--- a/airavata/api/sharing/SharingRegistryService.py
+++ b/airavata/api/sharing/SharingRegistryService.py
@@ -524,7 +524,7 @@ class Iface(object):
"""
pass
- def shareEntityWithUsers(self, domainId, entityId, userList, perssionTypeId, cascadePermission):
+ def shareEntityWithUsers(self, domainId, entityId, userList, permissionTypeId, cascadePermission):
"""
<p>API method to share an entity with users</p>
@@ -532,12 +532,12 @@ class Iface(object):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
pass
- def revokeEntitySharingFromUsers(self, domainId, entityId, userList, perssionTypeId):
+ def revokeEntitySharingFromUsers(self, domainId, entityId, userList, permissionTypeId):
"""
<p>API method to revoke sharing from a list of users</p>
@@ -545,11 +545,11 @@ class Iface(object):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
"""
pass
- def shareEntityWithGroups(self, domainId, entityId, groupList, perssionTypeId, cascadePermission):
+ def shareEntityWithGroups(self, domainId, entityId, groupList, permissionTypeId, cascadePermission):
"""
<p>API method to share an entity with list of groups</p>
@@ -557,12 +557,12 @@ class Iface(object):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
pass
- def revokeEntitySharingFromGroups(self, domainId, entityId, groupList, perssionTypeId):
+ def revokeEntitySharingFromGroups(self, domainId, entityId, groupList, permissionTypeId):
"""
<p>API method to revoke sharing from list of users</p>
@@ -570,7 +570,7 @@ class Iface(object):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
"""
pass
@@ -2465,7 +2465,7 @@ class Client(Iface):
raise result.sre
raise TApplicationException(TApplicationException.MISSING_RESULT, "getPermissionTypes failed: unknown result")
- def shareEntityWithUsers(self, domainId, entityId, userList, perssionTypeId, cascadePermission):
+ def shareEntityWithUsers(self, domainId, entityId, userList, permissionTypeId, cascadePermission):
"""
<p>API method to share an entity with users</p>
@@ -2473,19 +2473,19 @@ class Client(Iface):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
- self.send_shareEntityWithUsers(domainId, entityId, userList, perssionTypeId, cascadePermission)
+ self.send_shareEntityWithUsers(domainId, entityId, userList, permissionTypeId, cascadePermission)
return self.recv_shareEntityWithUsers()
- def send_shareEntityWithUsers(self, domainId, entityId, userList, perssionTypeId, cascadePermission):
+ def send_shareEntityWithUsers(self, domainId, entityId, userList, permissionTypeId, cascadePermission):
self._oprot.writeMessageBegin('shareEntityWithUsers', TMessageType.CALL, self._seqid)
args = shareEntityWithUsers_args()
args.domainId = domainId
args.entityId = entityId
args.userList = userList
- args.perssionTypeId = perssionTypeId
+ args.permissionTypeId = permissionTypeId
args.cascadePermission = cascadePermission
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -2508,7 +2508,7 @@ class Client(Iface):
raise result.sre
raise TApplicationException(TApplicationException.MISSING_RESULT, "shareEntityWithUsers failed: unknown result")
- def revokeEntitySharingFromUsers(self, domainId, entityId, userList, perssionTypeId):
+ def revokeEntitySharingFromUsers(self, domainId, entityId, userList, permissionTypeId):
"""
<p>API method to revoke sharing from a list of users</p>
@@ -2516,18 +2516,18 @@ class Client(Iface):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
"""
- self.send_revokeEntitySharingFromUsers(domainId, entityId, userList, perssionTypeId)
+ self.send_revokeEntitySharingFromUsers(domainId, entityId, userList, permissionTypeId)
return self.recv_revokeEntitySharingFromUsers()
- def send_revokeEntitySharingFromUsers(self, domainId, entityId, userList, perssionTypeId):
+ def send_revokeEntitySharingFromUsers(self, domainId, entityId, userList, permissionTypeId):
self._oprot.writeMessageBegin('revokeEntitySharingFromUsers', TMessageType.CALL, self._seqid)
args = revokeEntitySharingFromUsers_args()
args.domainId = domainId
args.entityId = entityId
args.userList = userList
- args.perssionTypeId = perssionTypeId
+ args.permissionTypeId = permissionTypeId
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -2549,7 +2549,7 @@ class Client(Iface):
raise result.sre
raise TApplicationException(TApplicationException.MISSING_RESULT, "revokeEntitySharingFromUsers failed: unknown result")
- def shareEntityWithGroups(self, domainId, entityId, groupList, perssionTypeId, cascadePermission):
+ def shareEntityWithGroups(self, domainId, entityId, groupList, permissionTypeId, cascadePermission):
"""
<p>API method to share an entity with list of groups</p>
@@ -2557,19 +2557,19 @@ class Client(Iface):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
- self.send_shareEntityWithGroups(domainId, entityId, groupList, perssionTypeId, cascadePermission)
+ self.send_shareEntityWithGroups(domainId, entityId, groupList, permissionTypeId, cascadePermission)
return self.recv_shareEntityWithGroups()
- def send_shareEntityWithGroups(self, domainId, entityId, groupList, perssionTypeId, cascadePermission):
+ def send_shareEntityWithGroups(self, domainId, entityId, groupList, permissionTypeId, cascadePermission):
self._oprot.writeMessageBegin('shareEntityWithGroups', TMessageType.CALL, self._seqid)
args = shareEntityWithGroups_args()
args.domainId = domainId
args.entityId = entityId
args.groupList = groupList
- args.perssionTypeId = perssionTypeId
+ args.permissionTypeId = permissionTypeId
args.cascadePermission = cascadePermission
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -2592,7 +2592,7 @@ class Client(Iface):
raise result.sre
raise TApplicationException(TApplicationException.MISSING_RESULT, "shareEntityWithGroups failed: unknown result")
- def revokeEntitySharingFromGroups(self, domainId, entityId, groupList, perssionTypeId):
+ def revokeEntitySharingFromGroups(self, domainId, entityId, groupList, permissionTypeId):
"""
<p>API method to revoke sharing from list of users</p>
@@ -2600,18 +2600,18 @@ class Client(Iface):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
"""
- self.send_revokeEntitySharingFromGroups(domainId, entityId, groupList, perssionTypeId)
+ self.send_revokeEntitySharingFromGroups(domainId, entityId, groupList, permissionTypeId)
return self.recv_revokeEntitySharingFromGroups()
- def send_revokeEntitySharingFromGroups(self, domainId, entityId, groupList, perssionTypeId):
+ def send_revokeEntitySharingFromGroups(self, domainId, entityId, groupList, permissionTypeId):
self._oprot.writeMessageBegin('revokeEntitySharingFromGroups', TMessageType.CALL, self._seqid)
args = revokeEntitySharingFromGroups_args()
args.domainId = domainId
args.entityId = entityId
args.groupList = groupList
- args.perssionTypeId = perssionTypeId
+ args.permissionTypeId = permissionTypeId
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -3865,7 +3865,7 @@ class Processor(Iface, TProcessor):
iprot.readMessageEnd()
result = shareEntityWithUsers_result()
try:
- result.success = self._handler.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId, args.cascadePermission)
+ result.success = self._handler.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.permissionTypeId, args.cascadePermission)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -3887,7 +3887,7 @@ class Processor(Iface, TProcessor):
iprot.readMessageEnd()
result = revokeEntitySharingFromUsers_result()
try:
- result.success = self._handler.revokeEntitySharingFromUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId)
+ result.success = self._handler.revokeEntitySharingFromUsers(args.domainId, args.entityId, args.userList, args.permissionTypeId)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -3909,7 +3909,7 @@ class Processor(Iface, TProcessor):
iprot.readMessageEnd()
result = shareEntityWithGroups_result()
try:
- result.success = self._handler.shareEntityWithGroups(args.domainId, args.entityId, args.groupList, args.perssionTypeId, args.cascadePermission)
+ result.success = self._handler.shareEntityWithGroups(args.domainId, args.entityId, args.groupList, args.permissionTypeId, args.cascadePermission)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -3931,7 +3931,7 @@ class Processor(Iface, TProcessor):
iprot.readMessageEnd()
result = revokeEntitySharingFromGroups_result()
try:
- result.success = self._handler.revokeEntitySharingFromGroups(args.domainId, args.entityId, args.groupList, args.perssionTypeId)
+ result.success = self._handler.revokeEntitySharingFromGroups(args.domainId, args.entityId, args.groupList, args.permissionTypeId)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -11679,7 +11679,7 @@ class shareEntityWithUsers_args(object):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
@@ -11688,15 +11688,15 @@ class shareEntityWithUsers_args(object):
(1, TType.STRING, 'domainId', 'UTF8', None, ), # 1
(2, TType.STRING, 'entityId', 'UTF8', None, ), # 2
(3, TType.LIST, 'userList', (TType.STRING, 'UTF8', False), None, ), # 3
- (4, TType.STRING, 'perssionTypeId', 'UTF8', None, ), # 4
+ (4, TType.STRING, 'permissionTypeId', 'UTF8', None, ), # 4
(5, TType.BOOL, 'cascadePermission', None, None, ), # 5
)
- def __init__(self, domainId=None, entityId=None, userList=None, perssionTypeId=None, cascadePermission=None,):
+ def __init__(self, domainId=None, entityId=None, userList=None, permissionTypeId=None, cascadePermission=None,):
self.domainId = domainId
self.entityId = entityId
self.userList = userList
- self.perssionTypeId = perssionTypeId
+ self.permissionTypeId = permissionTypeId
self.cascadePermission = cascadePermission
def read(self, iprot):
@@ -11730,7 +11730,7 @@ class shareEntityWithUsers_args(object):
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.perssionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.permissionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
@@ -11763,9 +11763,9 @@ class shareEntityWithUsers_args(object):
oprot.writeString(iter125.encode('utf-8') if sys.version_info[0] == 2 else iter125)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.perssionTypeId is not None:
- oprot.writeFieldBegin('perssionTypeId', TType.STRING, 4)
- oprot.writeString(self.perssionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.perssionTypeId)
+ if self.permissionTypeId is not None:
+ oprot.writeFieldBegin('permissionTypeId', TType.STRING, 4)
+ oprot.writeString(self.permissionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.permissionTypeId)
oprot.writeFieldEnd()
if self.cascadePermission is not None:
oprot.writeFieldBegin('cascadePermission', TType.BOOL, 5)
@@ -11781,8 +11781,8 @@ class shareEntityWithUsers_args(object):
raise TProtocolException(message='Required field entityId is unset!')
if self.userList is None:
raise TProtocolException(message='Required field userList is unset!')
- if self.perssionTypeId is None:
- raise TProtocolException(message='Required field perssionTypeId is unset!')
+ if self.permissionTypeId is None:
+ raise TProtocolException(message='Required field permissionTypeId is unset!')
if self.cascadePermission is None:
raise TProtocolException(message='Required field cascadePermission is unset!')
return
@@ -11877,7 +11877,7 @@ class revokeEntitySharingFromUsers_args(object):
- domainId
- entityId
- userList
- - perssionTypeId
+ - permissionTypeId
"""
thrift_spec = (
@@ -11885,14 +11885,14 @@ class revokeEntitySharingFromUsers_args(object):
(1, TType.STRING, 'domainId', 'UTF8', None, ), # 1
(2, TType.STRING, 'entityId', 'UTF8', None, ), # 2
(3, TType.LIST, 'userList', (TType.STRING, 'UTF8', False), None, ), # 3
- (4, TType.STRING, 'perssionTypeId', 'UTF8', None, ), # 4
+ (4, TType.STRING, 'permissionTypeId', 'UTF8', None, ), # 4
)
- def __init__(self, domainId=None, entityId=None, userList=None, perssionTypeId=None,):
+ def __init__(self, domainId=None, entityId=None, userList=None, permissionTypeId=None,):
self.domainId = domainId
self.entityId = entityId
self.userList = userList
- self.perssionTypeId = perssionTypeId
+ self.permissionTypeId = permissionTypeId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -11925,7 +11925,7 @@ class revokeEntitySharingFromUsers_args(object):
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.perssionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.permissionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -11953,9 +11953,9 @@ class revokeEntitySharingFromUsers_args(object):
oprot.writeString(iter132.encode('utf-8') if sys.version_info[0] == 2 else iter132)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.perssionTypeId is not None:
- oprot.writeFieldBegin('perssionTypeId', TType.STRING, 4)
- oprot.writeString(self.perssionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.perssionTypeId)
+ if self.permissionTypeId is not None:
+ oprot.writeFieldBegin('permissionTypeId', TType.STRING, 4)
+ oprot.writeString(self.permissionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.permissionTypeId)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -11967,8 +11967,8 @@ class revokeEntitySharingFromUsers_args(object):
raise TProtocolException(message='Required field entityId is unset!')
if self.userList is None:
raise TProtocolException(message='Required field userList is unset!')
- if self.perssionTypeId is None:
- raise TProtocolException(message='Required field perssionTypeId is unset!')
+ if self.permissionTypeId is None:
+ raise TProtocolException(message='Required field permissionTypeId is unset!')
return
def __repr__(self):
@@ -12061,7 +12061,7 @@ class shareEntityWithGroups_args(object):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
- cascadePermission
"""
@@ -12070,15 +12070,15 @@ class shareEntityWithGroups_args(object):
(1, TType.STRING, 'domainId', 'UTF8', None, ), # 1
(2, TType.STRING, 'entityId', 'UTF8', None, ), # 2
(3, TType.LIST, 'groupList', (TType.STRING, 'UTF8', False), None, ), # 3
- (4, TType.STRING, 'perssionTypeId', 'UTF8', None, ), # 4
+ (4, TType.STRING, 'permissionTypeId', 'UTF8', None, ), # 4
(5, TType.BOOL, 'cascadePermission', None, None, ), # 5
)
- def __init__(self, domainId=None, entityId=None, groupList=None, perssionTypeId=None, cascadePermission=None,):
+ def __init__(self, domainId=None, entityId=None, groupList=None, permissionTypeId=None, cascadePermission=None,):
self.domainId = domainId
self.entityId = entityId
self.groupList = groupList
- self.perssionTypeId = perssionTypeId
+ self.permissionTypeId = permissionTypeId
self.cascadePermission = cascadePermission
def read(self, iprot):
@@ -12112,7 +12112,7 @@ class shareEntityWithGroups_args(object):
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.perssionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.permissionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
@@ -12145,9 +12145,9 @@ class shareEntityWithGroups_args(object):
oprot.writeString(iter139.encode('utf-8') if sys.version_info[0] == 2 else iter139)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.perssionTypeId is not None:
- oprot.writeFieldBegin('perssionTypeId', TType.STRING, 4)
- oprot.writeString(self.perssionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.perssionTypeId)
+ if self.permissionTypeId is not None:
+ oprot.writeFieldBegin('permissionTypeId', TType.STRING, 4)
+ oprot.writeString(self.permissionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.permissionTypeId)
oprot.writeFieldEnd()
if self.cascadePermission is not None:
oprot.writeFieldBegin('cascadePermission', TType.BOOL, 5)
@@ -12163,8 +12163,8 @@ class shareEntityWithGroups_args(object):
raise TProtocolException(message='Required field entityId is unset!')
if self.groupList is None:
raise TProtocolException(message='Required field groupList is unset!')
- if self.perssionTypeId is None:
- raise TProtocolException(message='Required field perssionTypeId is unset!')
+ if self.permissionTypeId is None:
+ raise TProtocolException(message='Required field permissionTypeId is unset!')
if self.cascadePermission is None:
raise TProtocolException(message='Required field cascadePermission is unset!')
return
@@ -12259,7 +12259,7 @@ class revokeEntitySharingFromGroups_args(object):
- domainId
- entityId
- groupList
- - perssionTypeId
+ - permissionTypeId
"""
thrift_spec = (
@@ -12267,14 +12267,14 @@ class revokeEntitySharingFromGroups_args(object):
(1, TType.STRING, 'domainId', 'UTF8', None, ), # 1
(2, TType.STRING, 'entityId', 'UTF8', None, ), # 2
(3, TType.LIST, 'groupList', (TType.STRING, 'UTF8', False), None, ), # 3
- (4, TType.STRING, 'perssionTypeId', 'UTF8', None, ), # 4
+ (4, TType.STRING, 'permissionTypeId', 'UTF8', None, ), # 4
)
- def __init__(self, domainId=None, entityId=None, groupList=None, perssionTypeId=None,):
+ def __init__(self, domainId=None, entityId=None, groupList=None, permissionTypeId=None,):
self.domainId = domainId
self.entityId = entityId
self.groupList = groupList
- self.perssionTypeId = perssionTypeId
+ self.permissionTypeId = permissionTypeId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -12307,7 +12307,7 @@ class revokeEntitySharingFromGroups_args(object):
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.perssionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ self.permissionTypeId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -12335,9 +12335,9 @@ class revokeEntitySharingFromGroups_args(object):
oprot.writeString(iter146.encode('utf-8') if sys.version_info[0] == 2 else iter146)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.perssionTypeId is not None:
- oprot.writeFieldBegin('perssionTypeId', TType.STRING, 4)
- oprot.writeString(self.perssionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.perssionTypeId)
+ if self.permissionTypeId is not None:
+ oprot.writeFieldBegin('permissionTypeId', TType.STRING, 4)
+ oprot.writeString(self.permissionTypeId.encode('utf-8') if sys.version_info[0] == 2 else self.permissionTypeId)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -12349,8 +12349,8 @@ class revokeEntitySharingFromGroups_args(object):
raise TProtocolException(message='Required field entityId is unset!')
if self.groupList is None:
raise TProtocolException(message='Required field groupList is unset!')
- if self.perssionTypeId is None:
- raise TProtocolException(message='Required field perssionTypeId is unset!')
+ if self.permissionTypeId is None:
+ raise TProtocolException(message='Required field permissionTypeId is unset!')
return
def __repr__(self):
diff --git a/airavata/model/group/ttypes.py b/airavata/model/group/ttypes.py
index e2a8da4..db160ae 100644
--- a/airavata/model/group/ttypes.py
+++ b/airavata/model/group/ttypes.py
@@ -45,20 +45,17 @@ class ResourcePermissionType(object):
WRITE = 0
READ = 1
OWNER = 2
- EXEC = 3
_VALUES_TO_NAMES = {
0: "WRITE",
1: "READ",
2: "OWNER",
- 3: "EXEC",
}
_NAMES_TO_VALUES = {
"WRITE": 0,
"READ": 1,
"OWNER": 2,
- "EXEC": 3,
}
diff --git a/airavata/model/status/ttypes.py b/airavata/model/status/ttypes.py
index cd26873..4f70212 100644
--- a/airavata/model/status/ttypes.py
+++ b/airavata/model/status/ttypes.py
@@ -175,6 +175,7 @@ class ExperimentStatus(object):
- state
- timeOfStateChange
- reason
+ - statusId
"""
thrift_spec = (
@@ -182,12 +183,14 @@ class ExperimentStatus(object):
(1, TType.I32, 'state', None, None, ), # 1
(2, TType.I64, 'timeOfStateChange', None, None, ), # 2
(3, TType.STRING, 'reason', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'statusId', 'UTF8', None, ), # 4
)
- def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+ def __init__(self, state=None, timeOfStateChange=None, reason=None, statusId=None,):
self.state = state
self.timeOfStateChange = timeOfStateChange
self.reason = reason
+ self.statusId = statusId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -213,6 +216,11 @@ class ExperimentStatus(object):
self.reason = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.statusId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -235,6 +243,10 @@ class ExperimentStatus(object):
oprot.writeFieldBegin('reason', TType.STRING, 3)
oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
oprot.writeFieldEnd()
+ if self.statusId is not None:
+ oprot.writeFieldBegin('statusId', TType.STRING, 4)
+ oprot.writeString(self.statusId.encode('utf-8') if sys.version_info[0] == 2 else self.statusId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -261,6 +273,7 @@ class ProcessStatus(object):
- state
- timeOfStateChange
- reason
+ - statusId
"""
thrift_spec = (
@@ -268,12 +281,14 @@ class ProcessStatus(object):
(1, TType.I32, 'state', None, None, ), # 1
(2, TType.I64, 'timeOfStateChange', None, None, ), # 2
(3, TType.STRING, 'reason', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'statusId', 'UTF8', None, ), # 4
)
- def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+ def __init__(self, state=None, timeOfStateChange=None, reason=None, statusId=None,):
self.state = state
self.timeOfStateChange = timeOfStateChange
self.reason = reason
+ self.statusId = statusId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -299,6 +314,11 @@ class ProcessStatus(object):
self.reason = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.statusId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -321,6 +341,10 @@ class ProcessStatus(object):
oprot.writeFieldBegin('reason', TType.STRING, 3)
oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
oprot.writeFieldEnd()
+ if self.statusId is not None:
+ oprot.writeFieldBegin('statusId', TType.STRING, 4)
+ oprot.writeString(self.statusId.encode('utf-8') if sys.version_info[0] == 2 else self.statusId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -347,6 +371,7 @@ class TaskStatus(object):
- state
- timeOfStateChange
- reason
+ - statusId
"""
thrift_spec = (
@@ -354,12 +379,14 @@ class TaskStatus(object):
(1, TType.I32, 'state', None, None, ), # 1
(2, TType.I64, 'timeOfStateChange', None, None, ), # 2
(3, TType.STRING, 'reason', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'statusId', 'UTF8', None, ), # 4
)
- def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+ def __init__(self, state=None, timeOfStateChange=None, reason=None, statusId=None,):
self.state = state
self.timeOfStateChange = timeOfStateChange
self.reason = reason
+ self.statusId = statusId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -385,6 +412,11 @@ class TaskStatus(object):
self.reason = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.statusId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -407,6 +439,10 @@ class TaskStatus(object):
oprot.writeFieldBegin('reason', TType.STRING, 3)
oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
oprot.writeFieldEnd()
+ if self.statusId is not None:
+ oprot.writeFieldBegin('statusId', TType.STRING, 4)
+ oprot.writeString(self.statusId.encode('utf-8') if sys.version_info[0] == 2 else self.statusId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -433,6 +469,7 @@ class JobStatus(object):
- jobState
- timeOfStateChange
- reason
+ - statusId
"""
thrift_spec = (
@@ -440,12 +477,14 @@ class JobStatus(object):
(1, TType.I32, 'jobState', None, None, ), # 1
(2, TType.I64, 'timeOfStateChange', None, None, ), # 2
(3, TType.STRING, 'reason', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'statusId', 'UTF8', None, ), # 4
)
- def __init__(self, jobState=None, timeOfStateChange=None, reason=None,):
+ def __init__(self, jobState=None, timeOfStateChange=None, reason=None, statusId=None,):
self.jobState = jobState
self.timeOfStateChange = timeOfStateChange
self.reason = reason
+ self.statusId = statusId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -471,6 +510,11 @@ class JobStatus(object):
self.reason = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.statusId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -493,6 +537,10 @@ class JobStatus(object):
oprot.writeFieldBegin('reason', TType.STRING, 3)
oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
oprot.writeFieldEnd()
+ if self.statusId is not None:
+ oprot.writeFieldBegin('statusId', TType.STRING, 4)
+ oprot.writeString(self.statusId.encode('utf-8') if sys.version_info[0] == 2 else self.statusId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
--
To stop receiving notification emails like this one, please contact
machristie@apache.org.