You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ya...@apache.org on 2025/11/10 23:45:45 UTC
(airavata) 06/28: regenerate thrift ttypes for python sdk
This is an automated email from the ASF dual-hosted git repository.
yasith pushed a commit to branch resource-mgmt-rest-api
in repository https://gitbox.apache.org/repos/asf/airavata.git
commit fbaf7d2451bee221c5e1db3174b5995bfe752e59
Author: yasithdev <ya...@icloud.com>
AuthorDate: Wed Oct 29 14:25:57 2025 -0500
regenerate thrift ttypes for python sdk
---
.../airavata/model/experiment/ttypes.py | 14 +++++++++++++-
.../airavata-python-sdk/airavata/model/process/ttypes.py | 14 +++++++++++++-
2 files changed, 26 insertions(+), 2 deletions(-)
diff --git a/dev-tools/airavata-python-sdk/airavata/model/experiment/ttypes.py b/dev-tools/airavata-python-sdk/airavata/model/experiment/ttypes.py
index 99ccd9229e..b40f86e6d6 100644
--- a/dev-tools/airavata-python-sdk/airavata/model/experiment/ttypes.py
+++ b/dev-tools/airavata-python-sdk/airavata/model/experiment/ttypes.py
@@ -70,12 +70,13 @@ class UserConfigurationDataModel(object):
- useUserCRPref
- groupResourceProfileId
- autoScheduledCompResourceSchedulingList
+ - outputStorageResourceId
"""
thrift_spec: typing.Any = None
- def __init__(self, airavataAutoSchedule: bool = False, overrideManualScheduledParams: bool = False, shareExperimentPublicly: typing.Optional[bool] = False, computationalResourceScheduling: typing.Optional[airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel] = None, throttleResources: typing.Optional[bool] = False, userDN: typing.Optional[str] = None, generateCert: typing.Optional[bool] = False, storageId: typing.Optional[str] = None, experimentDataDir: typing.Option [...]
+ def __init__(self, airavataAutoSchedule: bool = False, overrideManualScheduledParams: bool = False, shareExperimentPublicly: typing.Optional[bool] = False, computationalResourceScheduling: typing.Optional[airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel] = None, throttleResources: typing.Optional[bool] = False, userDN: typing.Optional[str] = None, generateCert: typing.Optional[bool] = False, storageId: typing.Optional[str] = None, experimentDataDir: typing.Option [...]
self.airavataAutoSchedule: bool = airavataAutoSchedule
self.overrideManualScheduledParams: bool = overrideManualScheduledParams
self.shareExperimentPublicly: typing.Optional[bool] = shareExperimentPublicly
@@ -88,6 +89,7 @@ class UserConfigurationDataModel(object):
self.useUserCRPref: typing.Optional[bool] = useUserCRPref
self.groupResourceProfileId: typing.Optional[str] = groupResourceProfileId
self.autoScheduledCompResourceSchedulingList: typing.Optional[list[airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel]] = autoScheduledCompResourceSchedulingList
+ self.outputStorageResourceId: typing.Optional[str] = outputStorageResourceId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -165,6 +167,11 @@ class UserConfigurationDataModel(object):
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 13:
+ if ftype == TType.STRING:
+ self.outputStorageResourceId = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -227,6 +234,10 @@ class UserConfigurationDataModel(object):
iter6.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
+ if self.outputStorageResourceId is not None:
+ oprot.writeFieldBegin('outputStorageResourceId', TType.STRING, 13)
+ oprot.writeString(self.outputStorageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.outputStorageResourceId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -1044,6 +1055,7 @@ UserConfigurationDataModel.thrift_spec = (
(10, TType.BOOL, 'useUserCRPref', None, None, ), # 10
(11, TType.STRING, 'groupResourceProfileId', 'UTF8', None, ), # 11
(12, TType.LIST, 'autoScheduledCompResourceSchedulingList', (TType.STRUCT, [airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, None], False), None, ), # 12
+ (13, TType.STRING, 'outputStorageResourceId', 'UTF8', None, ), # 13
)
all_structs.append(ExperimentModel)
ExperimentModel.thrift_spec = (
diff --git a/dev-tools/airavata-python-sdk/airavata/model/process/ttypes.py b/dev-tools/airavata-python-sdk/airavata/model/process/ttypes.py
index 1f6a0f8272..0f2456df6b 100644
--- a/dev-tools/airavata-python-sdk/airavata/model/process/ttypes.py
+++ b/dev-tools/airavata-python-sdk/airavata/model/process/ttypes.py
@@ -158,12 +158,13 @@ class ProcessModel(object):
- useUserCRPref
- groupResourceProfileId
- processWorkflows
+ - outputStorageResourceId
"""
thrift_spec: typing.Any = None
- def __init__(self, processId: str = "DO_NOT_SET_AT_CLIENTS", experimentId: str = None, creationTime: typing.Optional[int] = None, lastUpdateTime: typing.Optional[int] = None, processStatuses: typing.Optional[list[airavata.model.status.ttypes.ProcessStatus]] = None, processDetail: typing.Optional[str] = None, applicationInterfaceId: typing.Optional[str] = None, applicationDeploymentId: typing.Optional[str] = None, computeResourceId: typing.Optional[str] = None, processInputs: typing.O [...]
+ def __init__(self, processId: str = "DO_NOT_SET_AT_CLIENTS", experimentId: str = None, creationTime: typing.Optional[int] = None, lastUpdateTime: typing.Optional[int] = None, processStatuses: typing.Optional[list[airavata.model.status.ttypes.ProcessStatus]] = None, processDetail: typing.Optional[str] = None, applicationInterfaceId: typing.Optional[str] = None, applicationDeploymentId: typing.Optional[str] = None, computeResourceId: typing.Optional[str] = None, processInputs: typing.O [...]
self.processId: str = processId
self.experimentId: str = experimentId
self.creationTime: typing.Optional[int] = creationTime
@@ -190,6 +191,7 @@ class ProcessModel(object):
self.useUserCRPref: typing.Optional[bool] = useUserCRPref
self.groupResourceProfileId: typing.Optional[str] = groupResourceProfileId
self.processWorkflows: typing.Optional[list[ProcessWorkflow]] = processWorkflows
+ self.outputStorageResourceId: typing.Optional[str] = outputStorageResourceId
def read(self, iprot):
if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
@@ -372,6 +374,11 @@ class ProcessModel(object):
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 27:
+ if ftype == TType.STRING:
+ self.outputStorageResourceId = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -508,6 +515,10 @@ class ProcessModel(object):
iter48.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
+ if self.outputStorageResourceId is not None:
+ oprot.writeFieldBegin('outputStorageResourceId', TType.STRING, 27)
+ oprot.writeString(self.outputStorageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.outputStorageResourceId)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -565,6 +576,7 @@ ProcessModel.thrift_spec = (
(24, TType.BOOL, 'useUserCRPref', None, None, ), # 24
(25, TType.STRING, 'groupResourceProfileId', 'UTF8', None, ), # 25
(26, TType.LIST, 'processWorkflows', (TType.STRUCT, [ProcessWorkflow, None], False), None, ), # 26
+ (27, TType.STRING, 'outputStorageResourceId', 'UTF8', None, ), # 27
)
fix_spec(all_structs)
del all_structs