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 <[email protected]> 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
