http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workflow/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workflow/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workflow/ttypes.py index 8aa21e7..a18a061 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workflow/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workflow/ttypes.py @@ -19,16 +19,77 @@ except: fastbinary = None +class WorkflowState: + CREATED = 0 + STARTED = 1 + EXECUTING = 2 + COMPLETED = 3 + FAILED = 4 + CANCELLING = 5 + CANCELED = 6 -class Workflow: + _VALUES_TO_NAMES = { + 0: "CREATED", + 1: "STARTED", + 2: "EXECUTING", + 3: "COMPLETED", + 4: "FAILED", + 5: "CANCELLING", + 6: "CANCELED", + } + + _NAMES_TO_VALUES = { + "CREATED": 0, + "STARTED": 1, + "EXECUTING": 2, + "COMPLETED": 3, + "FAILED": 4, + "CANCELLING": 5, + "CANCELED": 6, + } + +class ComponentState: + CREATED = 0 + WAITING = 1 + READY = 2 + RUNNING = 3 + COMPLETED = 4 + FAILED = 5 + CANCELED = 6 + + _VALUES_TO_NAMES = { + 0: "CREATED", + 1: "WAITING", + 2: "READY", + 3: "RUNNING", + 4: "COMPLETED", + 5: "FAILED", + 6: "CANCELED", + } + + _NAMES_TO_VALUES = { + "CREATED": 0, + "WAITING": 1, + "READY": 2, + "RUNNING": 3, + "COMPLETED": 4, + "FAILED": 5, + "CANCELED": 6, + } + + +class WorkflowModel: """ Attributes: - templateId - name - graph + - gatewayId + - createdUser - image - workflowInputs - workflowOutputs + - creationTime """ thrift_spec = ( @@ -36,18 +97,24 @@ class Workflow: (1, TType.STRING, 'templateId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 (2, TType.STRING, 'name', None, None, ), # 2 (3, TType.STRING, 'graph', None, None, ), # 3 - (4, TType.STRING, 'image', None, None, ), # 4 - (5, TType.LIST, 'workflowInputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec)), None, ), # 5 - (6, TType.LIST, 'workflowOutputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 6 + (4, TType.STRING, 'gatewayId', None, None, ), # 4 + (5, TType.STRING, 'createdUser', None, None, ), # 5 + (6, TType.STRING, 'image', None, None, ), # 6 + (7, TType.LIST, 'workflowInputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec)), None, ), # 7 + (8, TType.LIST, 'workflowOutputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 8 + (9, TType.I64, 'creationTime', None, None, ), # 9 ) - def __init__(self, templateId=thrift_spec[1][4], name=None, graph=None, image=None, workflowInputs=None, workflowOutputs=None,): + def __init__(self, templateId=thrift_spec[1][4], name=None, graph=None, gatewayId=None, createdUser=None, image=None, workflowInputs=None, workflowOutputs=None, creationTime=None,): self.templateId = templateId self.name = name self.graph = graph + self.gatewayId = gatewayId + self.createdUser = createdUser self.image = image self.workflowInputs = workflowInputs self.workflowOutputs = workflowOutputs + self.creationTime = creationTime def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -75,10 +142,20 @@ class Workflow: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.image = iprot.readString() + self.gatewayId = iprot.readString() else: iprot.skip(ftype) elif fid == 5: + if ftype == TType.STRING: + self.createdUser = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.image = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: if ftype == TType.LIST: self.workflowInputs = [] (_etype3, _size0) = iprot.readListBegin() @@ -89,7 +166,7 @@ class Workflow: iprot.readListEnd() else: iprot.skip(ftype) - elif fid == 6: + elif fid == 8: if ftype == TType.LIST: self.workflowOutputs = [] (_etype9, _size6) = iprot.readListBegin() @@ -100,6 +177,11 @@ class Workflow: iprot.readListEnd() else: iprot.skip(ftype) + elif fid == 9: + if ftype == TType.I64: + self.creationTime = iprot.readI64() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -109,7 +191,7 @@ class Workflow: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('Workflow') + oprot.writeStructBegin('WorkflowModel') if self.templateId is not None: oprot.writeFieldBegin('templateId', TType.STRING, 1) oprot.writeString(self.templateId) @@ -122,24 +204,36 @@ class Workflow: oprot.writeFieldBegin('graph', TType.STRING, 3) oprot.writeString(self.graph) oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 4) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + if self.createdUser is not None: + oprot.writeFieldBegin('createdUser', TType.STRING, 5) + oprot.writeString(self.createdUser) + oprot.writeFieldEnd() if self.image is not None: - oprot.writeFieldBegin('image', TType.STRING, 4) + oprot.writeFieldBegin('image', TType.STRING, 6) oprot.writeString(self.image) oprot.writeFieldEnd() if self.workflowInputs is not None: - oprot.writeFieldBegin('workflowInputs', TType.LIST, 5) + oprot.writeFieldBegin('workflowInputs', TType.LIST, 7) oprot.writeListBegin(TType.STRUCT, len(self.workflowInputs)) for iter12 in self.workflowInputs: iter12.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.workflowOutputs is not None: - oprot.writeFieldBegin('workflowOutputs', TType.LIST, 6) + oprot.writeFieldBegin('workflowOutputs', TType.LIST, 8) oprot.writeListBegin(TType.STRUCT, len(self.workflowOutputs)) for iter13 in self.workflowOutputs: iter13.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() + if self.creationTime is not None: + oprot.writeFieldBegin('creationTime', TType.I64, 9) + oprot.writeI64(self.creationTime) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -148,6 +242,12 @@ class Workflow: raise TProtocol.TProtocolException(message='Required field templateId is unset!') if self.name is None: raise TProtocol.TProtocolException(message='Required field name is unset!') + if self.graph is None: + raise TProtocol.TProtocolException(message='Required field graph is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + if self.createdUser is None: + raise TProtocol.TProtocolException(message='Required field createdUser is unset!') return @@ -156,9 +256,558 @@ class Workflow: value = (value * 31) ^ hash(self.templateId) value = (value * 31) ^ hash(self.name) value = (value * 31) ^ hash(self.graph) + value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.createdUser) value = (value * 31) ^ hash(self.image) value = (value * 31) ^ hash(self.workflowInputs) value = (value * 31) ^ hash(self.workflowOutputs) + value = (value * 31) ^ hash(self.creationTime) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ComponentStatus: + """ + Attributes: + - state + - reason + - timeofStateChange + """ + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'state', None, 0, ), # 1 + (2, TType.STRING, 'reason', None, None, ), # 2 + (3, TType.I64, 'timeofStateChange', None, None, ), # 3 + ) + + def __init__(self, state=thrift_spec[1][4], reason=None, timeofStateChange=None,): + self.state = state + self.reason = reason + self.timeofStateChange = timeofStateChange + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.I32: + self.state = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.reason = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.timeofStateChange = iprot.readI64() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('ComponentStatus') + if self.state is not None: + oprot.writeFieldBegin('state', TType.I32, 1) + oprot.writeI32(self.state) + oprot.writeFieldEnd() + if self.reason is not None: + oprot.writeFieldBegin('reason', TType.STRING, 2) + oprot.writeString(self.reason) + oprot.writeFieldEnd() + if self.timeofStateChange is not None: + oprot.writeFieldBegin('timeofStateChange', TType.I64, 3) + oprot.writeI64(self.timeofStateChange) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.state is None: + raise TProtocol.TProtocolException(message='Required field state is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.state) + value = (value * 31) ^ hash(self.reason) + value = (value * 31) ^ hash(self.timeofStateChange) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class WorkflowStatus: + """ + Attributes: + - state + - timeOfStateChange + - reason + """ + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'state', None, None, ), # 1 + (2, TType.I64, 'timeOfStateChange', None, None, ), # 2 + (3, TType.STRING, 'reason', None, None, ), # 3 + ) + + def __init__(self, state=None, timeOfStateChange=None, reason=None,): + self.state = state + self.timeOfStateChange = timeOfStateChange + self.reason = reason + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.I32: + self.state = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.timeOfStateChange = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.reason = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('WorkflowStatus') + if self.state is not None: + oprot.writeFieldBegin('state', TType.I32, 1) + oprot.writeI32(self.state) + oprot.writeFieldEnd() + if self.timeOfStateChange is not None: + oprot.writeFieldBegin('timeOfStateChange', TType.I64, 2) + oprot.writeI64(self.timeOfStateChange) + oprot.writeFieldEnd() + if self.reason is not None: + oprot.writeFieldBegin('reason', TType.STRING, 3) + oprot.writeString(self.reason) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.state is None: + raise TProtocol.TProtocolException(message='Required field state is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.state) + value = (value * 31) ^ hash(self.timeOfStateChange) + value = (value * 31) ^ hash(self.reason) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class EdgeModel: + """ + Attributes: + - edgeId + - name + - status + - description + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'edgeId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'name', None, None, ), # 2 + (3, TType.STRUCT, 'status', (ComponentStatus, ComponentStatus.thrift_spec), None, ), # 3 + (4, TType.STRING, 'description', None, None, ), # 4 + ) + + def __init__(self, edgeId=thrift_spec[1][4], name=None, status=None, description=None,): + self.edgeId = edgeId + self.name = name + self.status = status + self.description = description + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.edgeId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.status = ComponentStatus() + self.status.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.description = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('EdgeModel') + if self.edgeId is not None: + oprot.writeFieldBegin('edgeId', TType.STRING, 1) + oprot.writeString(self.edgeId) + oprot.writeFieldEnd() + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 2) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.status is not None: + oprot.writeFieldBegin('status', TType.STRUCT, 3) + self.status.write(oprot) + oprot.writeFieldEnd() + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 4) + oprot.writeString(self.description) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.edgeId is None: + raise TProtocol.TProtocolException(message='Required field edgeId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.edgeId) + value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.description) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class PortModel: + """ + Attributes: + - portId + - name + - status + - value + - description + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'portId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'name', None, None, ), # 2 + (3, TType.STRUCT, 'status', (ComponentStatus, ComponentStatus.thrift_spec), None, ), # 3 + (4, TType.STRING, 'value', None, None, ), # 4 + (5, TType.STRING, 'description', None, None, ), # 5 + ) + + def __init__(self, portId=thrift_spec[1][4], name=None, status=None, value=None, description=None,): + self.portId = portId + self.name = name + self.status = status + self.value = value + self.description = description + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.portId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.status = ComponentStatus() + self.status.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.value = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.description = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('PortModel') + if self.portId is not None: + oprot.writeFieldBegin('portId', TType.STRING, 1) + oprot.writeString(self.portId) + oprot.writeFieldEnd() + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 2) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.status is not None: + oprot.writeFieldBegin('status', TType.STRUCT, 3) + self.status.write(oprot) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 4) + oprot.writeString(self.value) + oprot.writeFieldEnd() + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 5) + oprot.writeString(self.description) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.portId is None: + raise TProtocol.TProtocolException(message='Required field portId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.portId) + value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.value) + value = (value * 31) ^ hash(self.description) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class NodeModel: + """ + Attributes: + - nodeId + - name + - applicationId + - applicationName + - status + - description + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'nodeId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1 + (2, TType.STRING, 'name', None, None, ), # 2 + (3, TType.STRING, 'applicationId', None, None, ), # 3 + (4, TType.STRING, 'applicationName', None, None, ), # 4 + (5, TType.STRUCT, 'status', (ComponentStatus, ComponentStatus.thrift_spec), None, ), # 5 + (6, TType.STRING, 'description', None, None, ), # 6 + ) + + def __init__(self, nodeId=thrift_spec[1][4], name=None, applicationId=None, applicationName=None, status=None, description=None,): + self.nodeId = nodeId + self.name = name + self.applicationId = applicationId + self.applicationName = applicationName + self.status = status + self.description = description + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.nodeId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.applicationId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.applicationName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRUCT: + self.status = ComponentStatus() + self.status.read(iprot) + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.description = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('NodeModel') + if self.nodeId is not None: + oprot.writeFieldBegin('nodeId', TType.STRING, 1) + oprot.writeString(self.nodeId) + oprot.writeFieldEnd() + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 2) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.applicationId is not None: + oprot.writeFieldBegin('applicationId', TType.STRING, 3) + oprot.writeString(self.applicationId) + oprot.writeFieldEnd() + if self.applicationName is not None: + oprot.writeFieldBegin('applicationName', TType.STRING, 4) + oprot.writeString(self.applicationName) + oprot.writeFieldEnd() + if self.status is not None: + oprot.writeFieldBegin('status', TType.STRUCT, 5) + self.status.write(oprot) + oprot.writeFieldEnd() + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 6) + oprot.writeString(self.description) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.nodeId is None: + raise TProtocol.TProtocolException(message='Required field nodeId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.nodeId) + value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.applicationId) + value = (value * 31) ^ hash(self.applicationName) + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.description) return value def __repr__(self):
http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java index 020d395..f26fd55 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-01") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-08") public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus, ComponentStatus._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentStatus> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentStatus"); http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java index c71df88..1fd0a86 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-01") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-08") public class EdgeModel implements org.apache.thrift.TBase<EdgeModel, EdgeModel._Fields>, java.io.Serializable, Cloneable, Comparable<EdgeModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("EdgeModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java index e01c8d2..6658673 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-01") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-08") public class NodeModel implements org.apache.thrift.TBase<NodeModel, NodeModel._Fields>, java.io.Serializable, Cloneable, Comparable<NodeModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NodeModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java index 41cf054..b5b31dc 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-01") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-02-08") public class PortModel implements org.apache.thrift.TBase<PortModel, PortModel._Fields>, java.io.Serializable, Cloneable, Comparable<PortModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PortModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/4c790770/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java deleted file mode 100644 index 3460f9c..0000000 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/Workflow.java +++ /dev/null @@ -1,1055 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.airavata.model; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-15") -public class Workflow implements org.apache.thrift.TBase<Workflow, Workflow._Fields>, java.io.Serializable, Cloneable, Comparable<Workflow> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Workflow"); - - private static final org.apache.thrift.protocol.TField TEMPLATE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("templateId", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField GRAPH_FIELD_DESC = new org.apache.thrift.protocol.TField("graph", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField IMAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("image", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField WORKFLOW_INPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowInputs", org.apache.thrift.protocol.TType.LIST, (short)5); - private static final org.apache.thrift.protocol.TField WORKFLOW_OUTPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowOutputs", org.apache.thrift.protocol.TType.LIST, (short)6); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new WorkflowStandardSchemeFactory()); - schemes.put(TupleScheme.class, new WorkflowTupleSchemeFactory()); - } - - private String templateId; // required - private String name; // required - private String graph; // optional - private ByteBuffer image; // optional - private List<org.apache.airavata.model.application.io.InputDataObjectType> workflowInputs; // optional - private List<org.apache.airavata.model.application.io.OutputDataObjectType> workflowOutputs; // optional - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - TEMPLATE_ID((short)1, "templateId"), - NAME((short)2, "name"), - GRAPH((short)3, "graph"), - IMAGE((short)4, "image"), - WORKFLOW_INPUTS((short)5, "workflowInputs"), - WORKFLOW_OUTPUTS((short)6, "workflowOutputs"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // TEMPLATE_ID - return TEMPLATE_ID; - case 2: // NAME - return NAME; - case 3: // GRAPH - return GRAPH; - case 4: // IMAGE - return IMAGE; - case 5: // WORKFLOW_INPUTS - return WORKFLOW_INPUTS; - case 6: // WORKFLOW_OUTPUTS - return WORKFLOW_OUTPUTS; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final _Fields optionals[] = {_Fields.GRAPH,_Fields.IMAGE,_Fields.WORKFLOW_INPUTS,_Fields.WORKFLOW_OUTPUTS}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.TEMPLATE_ID, new org.apache.thrift.meta_data.FieldMetaData("templateId", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.GRAPH, new org.apache.thrift.meta_data.FieldMetaData("graph", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.IMAGE, new org.apache.thrift.meta_data.FieldMetaData("image", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.WORKFLOW_INPUTS, new org.apache.thrift.meta_data.FieldMetaData("workflowInputs", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.application.io.InputDataObjectType.class)))); - tmpMap.put(_Fields.WORKFLOW_OUTPUTS, new org.apache.thrift.meta_data.FieldMetaData("workflowOutputs", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.application.io.OutputDataObjectType.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Workflow.class, metaDataMap); - } - - public Workflow() { - this.templateId = "DO_NOT_SET_AT_CLIENTS"; - - } - - public Workflow( - String templateId, - String name) - { - this(); - this.templateId = templateId; - this.name = name; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Workflow(Workflow other) { - if (other.isSetTemplateId()) { - this.templateId = other.templateId; - } - if (other.isSetName()) { - this.name = other.name; - } - if (other.isSetGraph()) { - this.graph = other.graph; - } - if (other.isSetImage()) { - this.image = org.apache.thrift.TBaseHelper.copyBinary(other.image); - } - if (other.isSetWorkflowInputs()) { - List<org.apache.airavata.model.application.io.InputDataObjectType> __this__workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(other.workflowInputs.size()); - for (org.apache.airavata.model.application.io.InputDataObjectType other_element : other.workflowInputs) { - __this__workflowInputs.add(new org.apache.airavata.model.application.io.InputDataObjectType(other_element)); - } - this.workflowInputs = __this__workflowInputs; - } - if (other.isSetWorkflowOutputs()) { - List<org.apache.airavata.model.application.io.OutputDataObjectType> __this__workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(other.workflowOutputs.size()); - for (org.apache.airavata.model.application.io.OutputDataObjectType other_element : other.workflowOutputs) { - __this__workflowOutputs.add(new org.apache.airavata.model.application.io.OutputDataObjectType(other_element)); - } - this.workflowOutputs = __this__workflowOutputs; - } - } - - public Workflow deepCopy() { - return new Workflow(this); - } - - @Override - public void clear() { - this.templateId = "DO_NOT_SET_AT_CLIENTS"; - - this.name = null; - this.graph = null; - this.image = null; - this.workflowInputs = null; - this.workflowOutputs = null; - } - - public String getTemplateId() { - return this.templateId; - } - - public void setTemplateId(String templateId) { - this.templateId = templateId; - } - - public void unsetTemplateId() { - this.templateId = null; - } - - /** Returns true if field templateId is set (has been assigned a value) and false otherwise */ - public boolean isSetTemplateId() { - return this.templateId != null; - } - - public void setTemplateIdIsSet(boolean value) { - if (!value) { - this.templateId = null; - } - } - - public String getName() { - return this.name; - } - - public void setName(String name) { - this.name = name; - } - - public void unsetName() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean isSetName() { - return this.name != null; - } - - public void setNameIsSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public String getGraph() { - return this.graph; - } - - public void setGraph(String graph) { - this.graph = graph; - } - - public void unsetGraph() { - this.graph = null; - } - - /** Returns true if field graph is set (has been assigned a value) and false otherwise */ - public boolean isSetGraph() { - return this.graph != null; - } - - public void setGraphIsSet(boolean value) { - if (!value) { - this.graph = null; - } - } - - public byte[] getImage() { - setImage(org.apache.thrift.TBaseHelper.rightSize(image)); - return image == null ? null : image.array(); - } - - public ByteBuffer bufferForImage() { - return org.apache.thrift.TBaseHelper.copyBinary(image); - } - - public void setImage(byte[] image) { - this.image = image == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(image, image.length)); - } - - public void setImage(ByteBuffer image) { - this.image = org.apache.thrift.TBaseHelper.copyBinary(image); - } - - public void unsetImage() { - this.image = null; - } - - /** Returns true if field image is set (has been assigned a value) and false otherwise */ - public boolean isSetImage() { - return this.image != null; - } - - public void setImageIsSet(boolean value) { - if (!value) { - this.image = null; - } - } - - public int getWorkflowInputsSize() { - return (this.workflowInputs == null) ? 0 : this.workflowInputs.size(); - } - - public java.util.Iterator<org.apache.airavata.model.application.io.InputDataObjectType> getWorkflowInputsIterator() { - return (this.workflowInputs == null) ? null : this.workflowInputs.iterator(); - } - - public void addToWorkflowInputs(org.apache.airavata.model.application.io.InputDataObjectType elem) { - if (this.workflowInputs == null) { - this.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(); - } - this.workflowInputs.add(elem); - } - - public List<org.apache.airavata.model.application.io.InputDataObjectType> getWorkflowInputs() { - return this.workflowInputs; - } - - public void setWorkflowInputs(List<org.apache.airavata.model.application.io.InputDataObjectType> workflowInputs) { - this.workflowInputs = workflowInputs; - } - - public void unsetWorkflowInputs() { - this.workflowInputs = null; - } - - /** Returns true if field workflowInputs is set (has been assigned a value) and false otherwise */ - public boolean isSetWorkflowInputs() { - return this.workflowInputs != null; - } - - public void setWorkflowInputsIsSet(boolean value) { - if (!value) { - this.workflowInputs = null; - } - } - - public int getWorkflowOutputsSize() { - return (this.workflowOutputs == null) ? 0 : this.workflowOutputs.size(); - } - - public java.util.Iterator<org.apache.airavata.model.application.io.OutputDataObjectType> getWorkflowOutputsIterator() { - return (this.workflowOutputs == null) ? null : this.workflowOutputs.iterator(); - } - - public void addToWorkflowOutputs(org.apache.airavata.model.application.io.OutputDataObjectType elem) { - if (this.workflowOutputs == null) { - this.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(); - } - this.workflowOutputs.add(elem); - } - - public List<org.apache.airavata.model.application.io.OutputDataObjectType> getWorkflowOutputs() { - return this.workflowOutputs; - } - - public void setWorkflowOutputs(List<org.apache.airavata.model.application.io.OutputDataObjectType> workflowOutputs) { - this.workflowOutputs = workflowOutputs; - } - - public void unsetWorkflowOutputs() { - this.workflowOutputs = null; - } - - /** Returns true if field workflowOutputs is set (has been assigned a value) and false otherwise */ - public boolean isSetWorkflowOutputs() { - return this.workflowOutputs != null; - } - - public void setWorkflowOutputsIsSet(boolean value) { - if (!value) { - this.workflowOutputs = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TEMPLATE_ID: - if (value == null) { - unsetTemplateId(); - } else { - setTemplateId((String)value); - } - break; - - case NAME: - if (value == null) { - unsetName(); - } else { - setName((String)value); - } - break; - - case GRAPH: - if (value == null) { - unsetGraph(); - } else { - setGraph((String)value); - } - break; - - case IMAGE: - if (value == null) { - unsetImage(); - } else { - setImage((ByteBuffer)value); - } - break; - - case WORKFLOW_INPUTS: - if (value == null) { - unsetWorkflowInputs(); - } else { - setWorkflowInputs((List<org.apache.airavata.model.application.io.InputDataObjectType>)value); - } - break; - - case WORKFLOW_OUTPUTS: - if (value == null) { - unsetWorkflowOutputs(); - } else { - setWorkflowOutputs((List<org.apache.airavata.model.application.io.OutputDataObjectType>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TEMPLATE_ID: - return getTemplateId(); - - case NAME: - return getName(); - - case GRAPH: - return getGraph(); - - case IMAGE: - return getImage(); - - case WORKFLOW_INPUTS: - return getWorkflowInputs(); - - case WORKFLOW_OUTPUTS: - return getWorkflowOutputs(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case TEMPLATE_ID: - return isSetTemplateId(); - case NAME: - return isSetName(); - case GRAPH: - return isSetGraph(); - case IMAGE: - return isSetImage(); - case WORKFLOW_INPUTS: - return isSetWorkflowInputs(); - case WORKFLOW_OUTPUTS: - return isSetWorkflowOutputs(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Workflow) - return this.equals((Workflow)that); - return false; - } - - public boolean equals(Workflow that) { - if (that == null) - return false; - - boolean this_present_templateId = true && this.isSetTemplateId(); - boolean that_present_templateId = true && that.isSetTemplateId(); - if (this_present_templateId || that_present_templateId) { - if (!(this_present_templateId && that_present_templateId)) - return false; - if (!this.templateId.equals(that.templateId)) - return false; - } - - boolean this_present_name = true && this.isSetName(); - boolean that_present_name = true && that.isSetName(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_graph = true && this.isSetGraph(); - boolean that_present_graph = true && that.isSetGraph(); - if (this_present_graph || that_present_graph) { - if (!(this_present_graph && that_present_graph)) - return false; - if (!this.graph.equals(that.graph)) - return false; - } - - boolean this_present_image = true && this.isSetImage(); - boolean that_present_image = true && that.isSetImage(); - if (this_present_image || that_present_image) { - if (!(this_present_image && that_present_image)) - return false; - if (!this.image.equals(that.image)) - return false; - } - - boolean this_present_workflowInputs = true && this.isSetWorkflowInputs(); - boolean that_present_workflowInputs = true && that.isSetWorkflowInputs(); - if (this_present_workflowInputs || that_present_workflowInputs) { - if (!(this_present_workflowInputs && that_present_workflowInputs)) - return false; - if (!this.workflowInputs.equals(that.workflowInputs)) - return false; - } - - boolean this_present_workflowOutputs = true && this.isSetWorkflowOutputs(); - boolean that_present_workflowOutputs = true && that.isSetWorkflowOutputs(); - if (this_present_workflowOutputs || that_present_workflowOutputs) { - if (!(this_present_workflowOutputs && that_present_workflowOutputs)) - return false; - if (!this.workflowOutputs.equals(that.workflowOutputs)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_templateId = true && (isSetTemplateId()); - list.add(present_templateId); - if (present_templateId) - list.add(templateId); - - boolean present_name = true && (isSetName()); - list.add(present_name); - if (present_name) - list.add(name); - - boolean present_graph = true && (isSetGraph()); - list.add(present_graph); - if (present_graph) - list.add(graph); - - boolean present_image = true && (isSetImage()); - list.add(present_image); - if (present_image) - list.add(image); - - boolean present_workflowInputs = true && (isSetWorkflowInputs()); - list.add(present_workflowInputs); - if (present_workflowInputs) - list.add(workflowInputs); - - boolean present_workflowOutputs = true && (isSetWorkflowOutputs()); - list.add(present_workflowOutputs); - if (present_workflowOutputs) - list.add(workflowOutputs); - - return list.hashCode(); - } - - @Override - public int compareTo(Workflow other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetTemplateId()).compareTo(other.isSetTemplateId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTemplateId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.templateId, other.templateId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetGraph()).compareTo(other.isSetGraph()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetGraph()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.graph, other.graph); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetImage()).compareTo(other.isSetImage()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetImage()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.image, other.image); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetWorkflowInputs()).compareTo(other.isSetWorkflowInputs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetWorkflowInputs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowInputs, other.workflowInputs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetWorkflowOutputs()).compareTo(other.isSetWorkflowOutputs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetWorkflowOutputs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowOutputs, other.workflowOutputs); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("Workflow("); - boolean first = true; - - sb.append("templateId:"); - if (this.templateId == null) { - sb.append("null"); - } else { - sb.append(this.templateId); - } - first = false; - if (!first) sb.append(", "); - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - sb.append(this.name); - } - first = false; - if (isSetGraph()) { - if (!first) sb.append(", "); - sb.append("graph:"); - if (this.graph == null) { - sb.append("null"); - } else { - sb.append(this.graph); - } - first = false; - } - if (isSetImage()) { - if (!first) sb.append(", "); - sb.append("image:"); - if (this.image == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.image, sb); - } - first = false; - } - if (isSetWorkflowInputs()) { - if (!first) sb.append(", "); - sb.append("workflowInputs:"); - if (this.workflowInputs == null) { - sb.append("null"); - } else { - sb.append(this.workflowInputs); - } - first = false; - } - if (isSetWorkflowOutputs()) { - if (!first) sb.append(", "); - sb.append("workflowOutputs:"); - if (this.workflowOutputs == null) { - sb.append("null"); - } else { - sb.append(this.workflowOutputs); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!isSetTemplateId()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'templateId' is unset! Struct:" + toString()); - } - - if (!isSetName()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class WorkflowStandardSchemeFactory implements SchemeFactory { - public WorkflowStandardScheme getScheme() { - return new WorkflowStandardScheme(); - } - } - - private static class WorkflowStandardScheme extends StandardScheme<Workflow> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, Workflow struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // TEMPLATE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.templateId = iprot.readString(); - struct.setTemplateIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readString(); - struct.setNameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // GRAPH - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.graph = iprot.readString(); - struct.setGraphIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // IMAGE - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.image = iprot.readBinary(); - struct.setImageIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // WORKFLOW_INPUTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list0 = iprot.readListBegin(); - struct.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(_list0.size); - org.apache.airavata.model.application.io.InputDataObjectType _elem1; - for (int _i2 = 0; _i2 < _list0.size; ++_i2) - { - _elem1 = new org.apache.airavata.model.application.io.InputDataObjectType(); - _elem1.read(iprot); - struct.workflowInputs.add(_elem1); - } - iprot.readListEnd(); - } - struct.setWorkflowInputsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // WORKFLOW_OUTPUTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list3 = iprot.readListBegin(); - struct.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(_list3.size); - org.apache.airavata.model.application.io.OutputDataObjectType _elem4; - for (int _i5 = 0; _i5 < _list3.size; ++_i5) - { - _elem4 = new org.apache.airavata.model.application.io.OutputDataObjectType(); - _elem4.read(iprot); - struct.workflowOutputs.add(_elem4); - } - iprot.readListEnd(); - } - struct.setWorkflowOutputsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, Workflow struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.templateId != null) { - oprot.writeFieldBegin(TEMPLATE_ID_FIELD_DESC); - oprot.writeString(struct.templateId); - oprot.writeFieldEnd(); - } - if (struct.name != null) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeString(struct.name); - oprot.writeFieldEnd(); - } - if (struct.graph != null) { - if (struct.isSetGraph()) { - oprot.writeFieldBegin(GRAPH_FIELD_DESC); - oprot.writeString(struct.graph); - oprot.writeFieldEnd(); - } - } - if (struct.image != null) { - if (struct.isSetImage()) { - oprot.writeFieldBegin(IMAGE_FIELD_DESC); - oprot.writeBinary(struct.image); - oprot.writeFieldEnd(); - } - } - if (struct.workflowInputs != null) { - if (struct.isSetWorkflowInputs()) { - oprot.writeFieldBegin(WORKFLOW_INPUTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workflowInputs.size())); - for (org.apache.airavata.model.application.io.InputDataObjectType _iter6 : struct.workflowInputs) - { - _iter6.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.workflowOutputs != null) { - if (struct.isSetWorkflowOutputs()) { - oprot.writeFieldBegin(WORKFLOW_OUTPUTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workflowOutputs.size())); - for (org.apache.airavata.model.application.io.OutputDataObjectType _iter7 : struct.workflowOutputs) - { - _iter7.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class WorkflowTupleSchemeFactory implements SchemeFactory { - public WorkflowTupleScheme getScheme() { - return new WorkflowTupleScheme(); - } - } - - private static class WorkflowTupleScheme extends TupleScheme<Workflow> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, Workflow struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.templateId); - oprot.writeString(struct.name); - BitSet optionals = new BitSet(); - if (struct.isSetGraph()) { - optionals.set(0); - } - if (struct.isSetImage()) { - optionals.set(1); - } - if (struct.isSetWorkflowInputs()) { - optionals.set(2); - } - if (struct.isSetWorkflowOutputs()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetGraph()) { - oprot.writeString(struct.graph); - } - if (struct.isSetImage()) { - oprot.writeBinary(struct.image); - } - if (struct.isSetWorkflowInputs()) { - { - oprot.writeI32(struct.workflowInputs.size()); - for (org.apache.airavata.model.application.io.InputDataObjectType _iter8 : struct.workflowInputs) - { - _iter8.write(oprot); - } - } - } - if (struct.isSetWorkflowOutputs()) { - { - oprot.writeI32(struct.workflowOutputs.size()); - for (org.apache.airavata.model.application.io.OutputDataObjectType _iter9 : struct.workflowOutputs) - { - _iter9.write(oprot); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, Workflow struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.templateId = iprot.readString(); - struct.setTemplateIdIsSet(true); - struct.name = iprot.readString(); - struct.setNameIsSet(true); - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.graph = iprot.readString(); - struct.setGraphIsSet(true); - } - if (incoming.get(1)) { - struct.image = iprot.readBinary(); - struct.setImageIsSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TList _list10 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(_list10.size); - org.apache.airavata.model.application.io.InputDataObjectType _elem11; - for (int _i12 = 0; _i12 < _list10.size; ++_i12) - { - _elem11 = new org.apache.airavata.model.application.io.InputDataObjectType(); - _elem11.read(iprot); - struct.workflowInputs.add(_elem11); - } - } - struct.setWorkflowInputsIsSet(true); - } - if (incoming.get(3)) { - { - org.apache.thrift.protocol.TList _list13 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(_list13.size); - org.apache.airavata.model.application.io.OutputDataObjectType _elem14; - for (int _i15 = 0; _i15 < _list13.size; ++_i15) - { - _elem14 = new org.apache.airavata.model.application.io.OutputDataObjectType(); - _elem14.read(iprot); - struct.workflowOutputs.add(_elem14); - } - } - struct.setWorkflowOutputsIsSet(true); - } - } - } - -} -
