You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2016/02/08 17:49:25 UTC
[43/50] [abbrv] airavata git commit: update generated code and fixing
compilation issues
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);
- }
- }
- }
-
-}
-