You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2016/08/09 18:01:03 UTC
[23/32] airavata-sandbox git commit: Added_Apache
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.py
new file mode 100644
index 0000000..629dba2
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.py
@@ -0,0 +1,1426 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import apache.airavata.model.status.ttypes
+import apache.airavata.model.application.io.ttypes
+import apache.airavata.model.commons.ttypes
+
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol, TProtocol
+try:
+ from thrift.protocol import fastbinary
+except:
+ fastbinary = None
+
+
+class MessageLevel:
+ INFO = 0
+ DEBUG = 1
+ ERROR = 2
+ ACK = 3
+
+ _VALUES_TO_NAMES = {
+ 0: "INFO",
+ 1: "DEBUG",
+ 2: "ERROR",
+ 3: "ACK",
+ }
+
+ _NAMES_TO_VALUES = {
+ "INFO": 0,
+ "DEBUG": 1,
+ "ERROR": 2,
+ "ACK": 3,
+ }
+
+class MessageType:
+ EXPERIMENT = 0
+ TASK = 1
+ PROCESS = 2
+ JOB = 3
+ LAUNCHPROCESS = 4
+ TERMINATEPROCESS = 5
+ PROCESSOUTPUT = 6
+
+ _VALUES_TO_NAMES = {
+ 0: "EXPERIMENT",
+ 1: "TASK",
+ 2: "PROCESS",
+ 3: "JOB",
+ 4: "LAUNCHPROCESS",
+ 5: "TERMINATEPROCESS",
+ 6: "PROCESSOUTPUT",
+ }
+
+ _NAMES_TO_VALUES = {
+ "EXPERIMENT": 0,
+ "TASK": 1,
+ "PROCESS": 2,
+ "JOB": 3,
+ "LAUNCHPROCESS": 4,
+ "TERMINATEPROCESS": 5,
+ "PROCESSOUTPUT": 6,
+ }
+
+
+class ExperimentStatusChangeEvent:
+ """
+ Attributes:
+ - state
+ - experimentId
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRING, 'experimentId', None, None, ), # 2
+ (3, TType.STRING, 'gatewayId', None, None, ), # 3
+ )
+
+ def __init__(self, state=None, experimentId=None, gatewayId=None,):
+ self.state = state
+ self.experimentId = experimentId
+ self.gatewayId = gatewayId
+
+ 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.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('ExperimentStatusChangeEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 2)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 3)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 ProcessIdentifier:
+ """
+ Attributes:
+ - processId
+ - experimentId
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'processId', None, None, ), # 1
+ (2, TType.STRING, 'experimentId', None, None, ), # 2
+ (3, TType.STRING, 'gatewayId', None, None, ), # 3
+ )
+
+ def __init__(self, processId=None, experimentId=None, gatewayId=None,):
+ self.processId = processId
+ self.experimentId = experimentId
+ self.gatewayId = gatewayId
+
+ 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.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('ProcessIdentifier')
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 1)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 2)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 3)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 TaskIdentifier:
+ """
+ Attributes:
+ - taskId
+ - processId
+ - experimentId
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'taskId', None, None, ), # 1
+ (2, TType.STRING, 'processId', None, None, ), # 2
+ (3, TType.STRING, 'experimentId', None, None, ), # 3
+ (4, TType.STRING, 'gatewayId', None, None, ), # 4
+ )
+
+ def __init__(self, taskId=None, processId=None, experimentId=None, gatewayId=None,):
+ self.taskId = taskId
+ self.processId = processId
+ self.experimentId = experimentId
+ self.gatewayId = gatewayId
+
+ 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.taskId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('TaskIdentifier')
+ if self.taskId is not None:
+ oprot.writeFieldBegin('taskId', TType.STRING, 1)
+ oprot.writeString(self.taskId)
+ oprot.writeFieldEnd()
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 2)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 3)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 4)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.taskId is None:
+ raise TProtocol.TProtocolException(message='Required field taskId is unset!')
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.taskId)
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 TaskStatusChangeEvent:
+ """
+ Attributes:
+ - state
+ - taskIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, taskIdentity=None,):
+ self.state = state
+ self.taskIdentity = taskIdentity
+
+ 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.STRUCT:
+ self.taskIdentity = TaskIdentifier()
+ self.taskIdentity.read(iprot)
+ 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('TaskStatusChangeEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.taskIdentity is not None:
+ oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
+ self.taskIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.taskIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field taskIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.taskIdentity)
+ 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 TaskStatusChangeRequestEvent:
+ """
+ Attributes:
+ - state
+ - taskIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, taskIdentity=None,):
+ self.state = state
+ self.taskIdentity = taskIdentity
+
+ 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.STRUCT:
+ self.taskIdentity = TaskIdentifier()
+ self.taskIdentity.read(iprot)
+ 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('TaskStatusChangeRequestEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.taskIdentity is not None:
+ oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
+ self.taskIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.taskIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field taskIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.taskIdentity)
+ 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 ProcessStatusChangeEvent:
+ """
+ Attributes:
+ - state
+ - processIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'processIdentity', (ProcessIdentifier, ProcessIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, processIdentity=None,):
+ self.state = state
+ self.processIdentity = processIdentity
+
+ 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.STRUCT:
+ self.processIdentity = ProcessIdentifier()
+ self.processIdentity.read(iprot)
+ 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('ProcessStatusChangeEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.processIdentity is not None:
+ oprot.writeFieldBegin('processIdentity', TType.STRUCT, 2)
+ self.processIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.processIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field processIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.processIdentity)
+ 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 ProcessStatusChangeRequestEvent:
+ """
+ Attributes:
+ - state
+ - processIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'processIdentity', (ProcessIdentifier, ProcessIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, processIdentity=None,):
+ self.state = state
+ self.processIdentity = processIdentity
+
+ 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.STRUCT:
+ self.processIdentity = ProcessIdentifier()
+ self.processIdentity.read(iprot)
+ 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('ProcessStatusChangeRequestEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.processIdentity is not None:
+ oprot.writeFieldBegin('processIdentity', TType.STRUCT, 2)
+ self.processIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.processIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field processIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.processIdentity)
+ 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 TaskOutputChangeEvent:
+ """
+ Attributes:
+ - output
+ - taskIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'output', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 1
+ (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, output=None, taskIdentity=None,):
+ self.output = output
+ self.taskIdentity = taskIdentity
+
+ 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.LIST:
+ self.output = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in xrange(_size0):
+ _elem5 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem5.read(iprot)
+ self.output.append(_elem5)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.taskIdentity = TaskIdentifier()
+ self.taskIdentity.read(iprot)
+ 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('TaskOutputChangeEvent')
+ if self.output is not None:
+ oprot.writeFieldBegin('output', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.output))
+ for iter6 in self.output:
+ iter6.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.taskIdentity is not None:
+ oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
+ self.taskIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.output is None:
+ raise TProtocol.TProtocolException(message='Required field output is unset!')
+ if self.taskIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field taskIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.output)
+ value = (value * 31) ^ hash(self.taskIdentity)
+ 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 JobIdentifier:
+ """
+ Attributes:
+ - jobId
+ - taskId
+ - processId
+ - experimentId
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'jobId', None, None, ), # 1
+ (2, TType.STRING, 'taskId', None, None, ), # 2
+ (3, TType.STRING, 'processId', None, None, ), # 3
+ (4, TType.STRING, 'experimentId', None, None, ), # 4
+ (5, TType.STRING, 'gatewayId', None, None, ), # 5
+ )
+
+ def __init__(self, jobId=None, taskId=None, processId=None, experimentId=None, gatewayId=None,):
+ self.jobId = jobId
+ self.taskId = taskId
+ self.processId = processId
+ self.experimentId = experimentId
+ self.gatewayId = gatewayId
+
+ 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.jobId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.taskId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('JobIdentifier')
+ if self.jobId is not None:
+ oprot.writeFieldBegin('jobId', TType.STRING, 1)
+ oprot.writeString(self.jobId)
+ oprot.writeFieldEnd()
+ if self.taskId is not None:
+ oprot.writeFieldBegin('taskId', TType.STRING, 2)
+ oprot.writeString(self.taskId)
+ oprot.writeFieldEnd()
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 3)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 4)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 5)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.jobId is None:
+ raise TProtocol.TProtocolException(message='Required field jobId is unset!')
+ if self.taskId is None:
+ raise TProtocol.TProtocolException(message='Required field taskId is unset!')
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.jobId)
+ value = (value * 31) ^ hash(self.taskId)
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 ProcessSubmitEvent:
+ """
+ Attributes:
+ - processId
+ - gatewayId
+ - experimentId
+ - tokenId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'processId', None, None, ), # 1
+ (2, TType.STRING, 'gatewayId', None, None, ), # 2
+ (3, TType.STRING, 'experimentId', None, None, ), # 3
+ (4, TType.STRING, 'tokenId', None, None, ), # 4
+ )
+
+ def __init__(self, processId=None, gatewayId=None, experimentId=None, tokenId=None,):
+ self.processId = processId
+ self.gatewayId = gatewayId
+ self.experimentId = experimentId
+ self.tokenId = tokenId
+
+ 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.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.gatewayId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.tokenId = 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('ProcessSubmitEvent')
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 1)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 3)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.tokenId is not None:
+ oprot.writeFieldBegin('tokenId', TType.STRING, 4)
+ oprot.writeString(self.tokenId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ if self.tokenId is None:
+ raise TProtocol.TProtocolException(message='Required field tokenId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.tokenId)
+ 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 ProcessTerminateEvent:
+ """
+ Attributes:
+ - processId
+ - gatewayId
+ - tokenId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'processId', None, None, ), # 1
+ (2, TType.STRING, 'gatewayId', None, None, ), # 2
+ (3, TType.STRING, 'tokenId', None, None, ), # 3
+ )
+
+ def __init__(self, processId=None, gatewayId=None, tokenId=None,):
+ self.processId = processId
+ self.gatewayId = gatewayId
+ self.tokenId = tokenId
+
+ 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.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.gatewayId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.tokenId = 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('ProcessTerminateEvent')
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 1)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ if self.tokenId is not None:
+ oprot.writeFieldBegin('tokenId', TType.STRING, 3)
+ oprot.writeString(self.tokenId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ if self.tokenId is None:
+ raise TProtocol.TProtocolException(message='Required field tokenId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.gatewayId)
+ value = (value * 31) ^ hash(self.tokenId)
+ 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 JobStatusChangeEvent:
+ """
+ Attributes:
+ - state
+ - jobIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'jobIdentity', (JobIdentifier, JobIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, jobIdentity=None,):
+ self.state = state
+ self.jobIdentity = jobIdentity
+
+ 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.STRUCT:
+ self.jobIdentity = JobIdentifier()
+ self.jobIdentity.read(iprot)
+ 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('JobStatusChangeEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.jobIdentity is not None:
+ oprot.writeFieldBegin('jobIdentity', TType.STRUCT, 2)
+ self.jobIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.jobIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field jobIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.jobIdentity)
+ 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 JobStatusChangeRequestEvent:
+ """
+ Attributes:
+ - state
+ - jobIdentity
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'state', None, None, ), # 1
+ (2, TType.STRUCT, 'jobIdentity', (JobIdentifier, JobIdentifier.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, state=None, jobIdentity=None,):
+ self.state = state
+ self.jobIdentity = jobIdentity
+
+ 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.STRUCT:
+ self.jobIdentity = JobIdentifier()
+ self.jobIdentity.read(iprot)
+ 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('JobStatusChangeRequestEvent')
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 1)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.jobIdentity is not None:
+ oprot.writeFieldBegin('jobIdentity', TType.STRUCT, 2)
+ self.jobIdentity.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.state is None:
+ raise TProtocol.TProtocolException(message='Required field state is unset!')
+ if self.jobIdentity is None:
+ raise TProtocol.TProtocolException(message='Required field jobIdentity is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.jobIdentity)
+ 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 Message:
+ """
+ Attributes:
+ - event
+ - messageId
+ - messageType
+ - updatedTime
+ - messageLevel
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'event', None, None, ), # 1
+ (2, TType.STRING, 'messageId', None, "DO_NOT_SET_AT_CLIENTS", ), # 2
+ (3, TType.I32, 'messageType', None, None, ), # 3
+ (4, TType.I64, 'updatedTime', None, None, ), # 4
+ (5, TType.I32, 'messageLevel', None, None, ), # 5
+ )
+
+ def __init__(self, event=None, messageId=thrift_spec[2][4], messageType=None, updatedTime=None, messageLevel=None,):
+ self.event = event
+ self.messageId = messageId
+ self.messageType = messageType
+ self.updatedTime = updatedTime
+ self.messageLevel = messageLevel
+
+ 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.event = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.messageId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I32:
+ self.messageType = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I64:
+ self.updatedTime = iprot.readI64();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.messageLevel = iprot.readI32();
+ 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('Message')
+ if self.event is not None:
+ oprot.writeFieldBegin('event', TType.STRING, 1)
+ oprot.writeString(self.event)
+ oprot.writeFieldEnd()
+ if self.messageId is not None:
+ oprot.writeFieldBegin('messageId', TType.STRING, 2)
+ oprot.writeString(self.messageId)
+ oprot.writeFieldEnd()
+ if self.messageType is not None:
+ oprot.writeFieldBegin('messageType', TType.I32, 3)
+ oprot.writeI32(self.messageType)
+ oprot.writeFieldEnd()
+ if self.updatedTime is not None:
+ oprot.writeFieldBegin('updatedTime', TType.I64, 4)
+ oprot.writeI64(self.updatedTime)
+ oprot.writeFieldEnd()
+ if self.messageLevel is not None:
+ oprot.writeFieldBegin('messageLevel', TType.I32, 5)
+ oprot.writeI32(self.messageLevel)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.event is None:
+ raise TProtocol.TProtocolException(message='Required field event is unset!')
+ if self.messageId is None:
+ raise TProtocol.TProtocolException(message='Required field messageId is unset!')
+ if self.messageType is None:
+ raise TProtocol.TProtocolException(message='Required field messageType is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.event)
+ value = (value * 31) ^ hash(self.messageId)
+ value = (value * 31) ^ hash(self.messageType)
+ value = (value * 31) ^ hash(self.updatedTime)
+ value = (value * 31) ^ hash(self.messageLevel)
+ 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)
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.pyc
new file mode 100644
index 0000000..9f2282a
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/messaging/event/ttypes.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.pyc
new file mode 100644
index 0000000..fcb805d
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/__init__.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/constants.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/constants.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/constants.py
new file mode 100644
index 0000000..99717a9
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/constants.py
@@ -0,0 +1,11 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from ttypes import *
+
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.py
new file mode 100644
index 0000000..10104e4
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.py
@@ -0,0 +1,360 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import apache.airavata.model.commons.ttypes
+import apache.airavata.model.status.ttypes
+import apache.airavata.model.task.ttypes
+import apache.airavata.model.application.io.ttypes
+import apache.airavata.model.scheduling.ttypes
+
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol, TProtocol
+try:
+ from thrift.protocol import fastbinary
+except:
+ fastbinary = None
+
+
+
+class ProcessModel:
+ """
+ ProcessModel: A structure holding the process details. The infromation is derived based on user provided
+ configuration data or system inferred information from scheduling and QoS parameters.
+
+ processDetail:
+ A friendly description of the process, usally used to communicate information to users.
+
+
+
+ Attributes:
+ - processId
+ - experimentId
+ - creationTime
+ - lastUpdateTime
+ - processStatus
+ - processDetail
+ - applicationInterfaceId
+ - applicationDeploymentId
+ - computeResourceId
+ - processInputs
+ - processOutputs
+ - resourceSchedule
+ - tasks
+ - taskDag
+ - processError
+ - gatewayExecutionId
+ - enableEmailNotification
+ - emailAddresses
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'processId', None, "DO_NOT_SET_AT_CLIENTS", ), # 1
+ (2, TType.STRING, 'experimentId', None, None, ), # 2
+ (3, TType.I64, 'creationTime', None, None, ), # 3
+ (4, TType.I64, 'lastUpdateTime', None, None, ), # 4
+ (5, TType.STRUCT, 'processStatus', (apache.airavata.model.status.ttypes.ProcessStatus, apache.airavata.model.status.ttypes.ProcessStatus.thrift_spec), None, ), # 5
+ (6, TType.STRING, 'processDetail', None, None, ), # 6
+ (7, TType.STRING, 'applicationInterfaceId', None, None, ), # 7
+ (8, TType.STRING, 'applicationDeploymentId', None, None, ), # 8
+ (9, TType.STRING, 'computeResourceId', None, None, ), # 9
+ (10, TType.LIST, 'processInputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec)), None, ), # 10
+ (11, TType.LIST, 'processOutputs', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 11
+ (12, TType.STRUCT, 'resourceSchedule', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ), # 12
+ (13, TType.LIST, 'tasks', (TType.STRUCT,(apache.airavata.model.task.ttypes.TaskModel, apache.airavata.model.task.ttypes.TaskModel.thrift_spec)), None, ), # 13
+ (14, TType.STRING, 'taskDag', None, None, ), # 14
+ (15, TType.STRUCT, 'processError', (apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec), None, ), # 15
+ (16, TType.STRING, 'gatewayExecutionId', None, None, ), # 16
+ (17, TType.BOOL, 'enableEmailNotification', None, None, ), # 17
+ (18, TType.LIST, 'emailAddresses', (TType.STRING,None), None, ), # 18
+ )
+
+ def __init__(self, processId=thrift_spec[1][4], experimentId=None, creationTime=None, lastUpdateTime=None, processStatus=None, processDetail=None, applicationInterfaceId=None, applicationDeploymentId=None, computeResourceId=None, processInputs=None, processOutputs=None, resourceSchedule=None, tasks=None, taskDag=None, processError=None, gatewayExecutionId=None, enableEmailNotification=None, emailAddresses=None,):
+ self.processId = processId
+ self.experimentId = experimentId
+ self.creationTime = creationTime
+ self.lastUpdateTime = lastUpdateTime
+ self.processStatus = processStatus
+ self.processDetail = processDetail
+ self.applicationInterfaceId = applicationInterfaceId
+ self.applicationDeploymentId = applicationDeploymentId
+ self.computeResourceId = computeResourceId
+ self.processInputs = processInputs
+ self.processOutputs = processOutputs
+ self.resourceSchedule = resourceSchedule
+ self.tasks = tasks
+ self.taskDag = taskDag
+ self.processError = processError
+ self.gatewayExecutionId = gatewayExecutionId
+ self.enableEmailNotification = enableEmailNotification
+ self.emailAddresses = emailAddresses
+
+ 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.processId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.experimentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I64:
+ self.creationTime = iprot.readI64();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I64:
+ self.lastUpdateTime = iprot.readI64();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRUCT:
+ self.processStatus = apache.airavata.model.status.ttypes.ProcessStatus()
+ self.processStatus.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.processDetail = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.applicationInterfaceId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.applicationDeploymentId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.computeResourceId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.LIST:
+ self.processInputs = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in xrange(_size0):
+ _elem5 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
+ _elem5.read(iprot)
+ self.processInputs.append(_elem5)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.LIST:
+ self.processOutputs = []
+ (_etype9, _size6) = iprot.readListBegin()
+ for _i10 in xrange(_size6):
+ _elem11 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem11.read(iprot)
+ self.processOutputs.append(_elem11)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.STRUCT:
+ self.resourceSchedule = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel()
+ self.resourceSchedule.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 13:
+ if ftype == TType.LIST:
+ self.tasks = []
+ (_etype15, _size12) = iprot.readListBegin()
+ for _i16 in xrange(_size12):
+ _elem17 = apache.airavata.model.task.ttypes.TaskModel()
+ _elem17.read(iprot)
+ self.tasks.append(_elem17)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 14:
+ if ftype == TType.STRING:
+ self.taskDag = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 15:
+ if ftype == TType.STRUCT:
+ self.processError = apache.airavata.model.commons.ttypes.ErrorModel()
+ self.processError.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 16:
+ if ftype == TType.STRING:
+ self.gatewayExecutionId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 17:
+ if ftype == TType.BOOL:
+ self.enableEmailNotification = iprot.readBool();
+ else:
+ iprot.skip(ftype)
+ elif fid == 18:
+ if ftype == TType.LIST:
+ self.emailAddresses = []
+ (_etype21, _size18) = iprot.readListBegin()
+ for _i22 in xrange(_size18):
+ _elem23 = iprot.readString();
+ self.emailAddresses.append(_elem23)
+ iprot.readListEnd()
+ 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('ProcessModel')
+ if self.processId is not None:
+ oprot.writeFieldBegin('processId', TType.STRING, 1)
+ oprot.writeString(self.processId)
+ oprot.writeFieldEnd()
+ if self.experimentId is not None:
+ oprot.writeFieldBegin('experimentId', TType.STRING, 2)
+ oprot.writeString(self.experimentId)
+ oprot.writeFieldEnd()
+ if self.creationTime is not None:
+ oprot.writeFieldBegin('creationTime', TType.I64, 3)
+ oprot.writeI64(self.creationTime)
+ oprot.writeFieldEnd()
+ if self.lastUpdateTime is not None:
+ oprot.writeFieldBegin('lastUpdateTime', TType.I64, 4)
+ oprot.writeI64(self.lastUpdateTime)
+ oprot.writeFieldEnd()
+ if self.processStatus is not None:
+ oprot.writeFieldBegin('processStatus', TType.STRUCT, 5)
+ self.processStatus.write(oprot)
+ oprot.writeFieldEnd()
+ if self.processDetail is not None:
+ oprot.writeFieldBegin('processDetail', TType.STRING, 6)
+ oprot.writeString(self.processDetail)
+ oprot.writeFieldEnd()
+ if self.applicationInterfaceId is not None:
+ oprot.writeFieldBegin('applicationInterfaceId', TType.STRING, 7)
+ oprot.writeString(self.applicationInterfaceId)
+ oprot.writeFieldEnd()
+ if self.applicationDeploymentId is not None:
+ oprot.writeFieldBegin('applicationDeploymentId', TType.STRING, 8)
+ oprot.writeString(self.applicationDeploymentId)
+ oprot.writeFieldEnd()
+ if self.computeResourceId is not None:
+ oprot.writeFieldBegin('computeResourceId', TType.STRING, 9)
+ oprot.writeString(self.computeResourceId)
+ oprot.writeFieldEnd()
+ if self.processInputs is not None:
+ oprot.writeFieldBegin('processInputs', TType.LIST, 10)
+ oprot.writeListBegin(TType.STRUCT, len(self.processInputs))
+ for iter24 in self.processInputs:
+ iter24.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.processOutputs is not None:
+ oprot.writeFieldBegin('processOutputs', TType.LIST, 11)
+ oprot.writeListBegin(TType.STRUCT, len(self.processOutputs))
+ for iter25 in self.processOutputs:
+ iter25.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.resourceSchedule is not None:
+ oprot.writeFieldBegin('resourceSchedule', TType.STRUCT, 12)
+ self.resourceSchedule.write(oprot)
+ oprot.writeFieldEnd()
+ if self.tasks is not None:
+ oprot.writeFieldBegin('tasks', TType.LIST, 13)
+ oprot.writeListBegin(TType.STRUCT, len(self.tasks))
+ for iter26 in self.tasks:
+ iter26.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.taskDag is not None:
+ oprot.writeFieldBegin('taskDag', TType.STRING, 14)
+ oprot.writeString(self.taskDag)
+ oprot.writeFieldEnd()
+ if self.processError is not None:
+ oprot.writeFieldBegin('processError', TType.STRUCT, 15)
+ self.processError.write(oprot)
+ oprot.writeFieldEnd()
+ if self.gatewayExecutionId is not None:
+ oprot.writeFieldBegin('gatewayExecutionId', TType.STRING, 16)
+ oprot.writeString(self.gatewayExecutionId)
+ oprot.writeFieldEnd()
+ if self.enableEmailNotification is not None:
+ oprot.writeFieldBegin('enableEmailNotification', TType.BOOL, 17)
+ oprot.writeBool(self.enableEmailNotification)
+ oprot.writeFieldEnd()
+ if self.emailAddresses is not None:
+ oprot.writeFieldBegin('emailAddresses', TType.LIST, 18)
+ oprot.writeListBegin(TType.STRING, len(self.emailAddresses))
+ for iter27 in self.emailAddresses:
+ oprot.writeString(iter27)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.processId is None:
+ raise TProtocol.TProtocolException(message='Required field processId is unset!')
+ if self.experimentId is None:
+ raise TProtocol.TProtocolException(message='Required field experimentId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.processId)
+ value = (value * 31) ^ hash(self.experimentId)
+ value = (value * 31) ^ hash(self.creationTime)
+ value = (value * 31) ^ hash(self.lastUpdateTime)
+ value = (value * 31) ^ hash(self.processStatus)
+ value = (value * 31) ^ hash(self.processDetail)
+ value = (value * 31) ^ hash(self.applicationInterfaceId)
+ value = (value * 31) ^ hash(self.applicationDeploymentId)
+ value = (value * 31) ^ hash(self.computeResourceId)
+ value = (value * 31) ^ hash(self.processInputs)
+ value = (value * 31) ^ hash(self.processOutputs)
+ value = (value * 31) ^ hash(self.resourceSchedule)
+ value = (value * 31) ^ hash(self.tasks)
+ value = (value * 31) ^ hash(self.taskDag)
+ value = (value * 31) ^ hash(self.processError)
+ value = (value * 31) ^ hash(self.gatewayExecutionId)
+ value = (value * 31) ^ hash(self.enableEmailNotification)
+ value = (value * 31) ^ hash(self.emailAddresses)
+ 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)
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.pyc
new file mode 100644
index 0000000..0cd8bc7
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/process/ttypes.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.pyc
new file mode 100644
index 0000000..2a22351
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__init__.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/__init__.cpython-35.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/__init__.cpython-35.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/__init__.cpython-35.pyc
new file mode 100644
index 0000000..80348a6
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/__init__.cpython-35.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/ttypes.cpython-35.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/ttypes.cpython-35.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/ttypes.cpython-35.pyc
new file mode 100644
index 0000000..5fec2a5
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/__pycache__/ttypes.cpython-35.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/constants.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/constants.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/constants.py
new file mode 100644
index 0000000..99717a9
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/constants.py
@@ -0,0 +1,11 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from ttypes import *
+
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.py
new file mode 100644
index 0000000..a793f22
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.py
@@ -0,0 +1,191 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol, TProtocol
+try:
+ from thrift.protocol import fastbinary
+except:
+ fastbinary = None
+
+
+
+class ComputationalResourceSchedulingModel:
+ """
+ ComputationalResourceSchedulingModel:
+
+
+
+ Attributes:
+ - resourceHostId
+ - totalCPUCount
+ - nodeCount
+ - numberOfThreads
+ - queueName
+ - wallTimeLimit
+ - totalPhysicalMemory
+ - chessisNumber
+ - staticWorkingDir
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'resourceHostId', None, None, ), # 1
+ (2, TType.I32, 'totalCPUCount', None, None, ), # 2
+ (3, TType.I32, 'nodeCount', None, None, ), # 3
+ (4, TType.I32, 'numberOfThreads', None, None, ), # 4
+ (5, TType.STRING, 'queueName', None, None, ), # 5
+ (6, TType.I32, 'wallTimeLimit', None, None, ), # 6
+ (7, TType.I32, 'totalPhysicalMemory', None, None, ), # 7
+ (8, TType.STRING, 'chessisNumber', None, None, ), # 8
+ (9, TType.STRING, 'staticWorkingDir', None, None, ), # 9
+ )
+
+ def __init__(self, resourceHostId=None, totalCPUCount=None, nodeCount=None, numberOfThreads=None, queueName=None, wallTimeLimit=None, totalPhysicalMemory=None, chessisNumber=None, staticWorkingDir=None,):
+ self.resourceHostId = resourceHostId
+ self.totalCPUCount = totalCPUCount
+ self.nodeCount = nodeCount
+ self.numberOfThreads = numberOfThreads
+ self.queueName = queueName
+ self.wallTimeLimit = wallTimeLimit
+ self.totalPhysicalMemory = totalPhysicalMemory
+ self.chessisNumber = chessisNumber
+ self.staticWorkingDir = staticWorkingDir
+
+ 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.resourceHostId = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.totalCPUCount = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I32:
+ self.nodeCount = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.numberOfThreads = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.queueName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I32:
+ self.wallTimeLimit = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I32:
+ self.totalPhysicalMemory = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.chessisNumber = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.staticWorkingDir = 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('ComputationalResourceSchedulingModel')
+ if self.resourceHostId is not None:
+ oprot.writeFieldBegin('resourceHostId', TType.STRING, 1)
+ oprot.writeString(self.resourceHostId)
+ oprot.writeFieldEnd()
+ if self.totalCPUCount is not None:
+ oprot.writeFieldBegin('totalCPUCount', TType.I32, 2)
+ oprot.writeI32(self.totalCPUCount)
+ oprot.writeFieldEnd()
+ if self.nodeCount is not None:
+ oprot.writeFieldBegin('nodeCount', TType.I32, 3)
+ oprot.writeI32(self.nodeCount)
+ oprot.writeFieldEnd()
+ if self.numberOfThreads is not None:
+ oprot.writeFieldBegin('numberOfThreads', TType.I32, 4)
+ oprot.writeI32(self.numberOfThreads)
+ oprot.writeFieldEnd()
+ if self.queueName is not None:
+ oprot.writeFieldBegin('queueName', TType.STRING, 5)
+ oprot.writeString(self.queueName)
+ oprot.writeFieldEnd()
+ if self.wallTimeLimit is not None:
+ oprot.writeFieldBegin('wallTimeLimit', TType.I32, 6)
+ oprot.writeI32(self.wallTimeLimit)
+ oprot.writeFieldEnd()
+ if self.totalPhysicalMemory is not None:
+ oprot.writeFieldBegin('totalPhysicalMemory', TType.I32, 7)
+ oprot.writeI32(self.totalPhysicalMemory)
+ oprot.writeFieldEnd()
+ if self.chessisNumber is not None:
+ oprot.writeFieldBegin('chessisNumber', TType.STRING, 8)
+ oprot.writeString(self.chessisNumber)
+ oprot.writeFieldEnd()
+ if self.staticWorkingDir is not None:
+ oprot.writeFieldBegin('staticWorkingDir', TType.STRING, 9)
+ oprot.writeString(self.staticWorkingDir)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.resourceHostId)
+ value = (value * 31) ^ hash(self.totalCPUCount)
+ value = (value * 31) ^ hash(self.nodeCount)
+ value = (value * 31) ^ hash(self.numberOfThreads)
+ value = (value * 31) ^ hash(self.queueName)
+ value = (value * 31) ^ hash(self.wallTimeLimit)
+ value = (value * 31) ^ hash(self.totalPhysicalMemory)
+ value = (value * 31) ^ hash(self.chessisNumber)
+ value = (value * 31) ^ hash(self.staticWorkingDir)
+ 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)
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.pyc
new file mode 100644
index 0000000..6d883db
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/scheduling/ttypes.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.pyc
new file mode 100644
index 0000000..6193f08
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/__init__.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/constants.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/constants.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/constants.py
new file mode 100644
index 0000000..99717a9
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/constants.py
@@ -0,0 +1,11 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from ttypes import *
+
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.py
new file mode 100644
index 0000000..35540cf
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.py
@@ -0,0 +1,108 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol, TProtocol
+try:
+ from thrift.protocol import fastbinary
+except:
+ fastbinary = None
+
+
+
+class AuthzToken:
+ """
+ Attributes:
+ - accessToken
+ - claimsMap
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'accessToken', None, None, ), # 1
+ (2, TType.MAP, 'claimsMap', (TType.STRING,None,TType.STRING,None), None, ), # 2
+ )
+
+ def __init__(self, accessToken=None, claimsMap=None,):
+ self.accessToken = accessToken
+ self.claimsMap = claimsMap
+
+ 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.accessToken = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.MAP:
+ self.claimsMap = {}
+ (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin()
+ for _i4 in xrange(_size0):
+ _key5 = iprot.readString();
+ _val6 = iprot.readString();
+ self.claimsMap[_key5] = _val6
+ iprot.readMapEnd()
+ 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('AuthzToken')
+ if self.accessToken is not None:
+ oprot.writeFieldBegin('accessToken', TType.STRING, 1)
+ oprot.writeString(self.accessToken)
+ oprot.writeFieldEnd()
+ if self.claimsMap is not None:
+ oprot.writeFieldBegin('claimsMap', TType.MAP, 2)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.claimsMap))
+ for kiter7,viter8 in self.claimsMap.items():
+ oprot.writeString(kiter7)
+ oprot.writeString(viter8)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.accessToken is None:
+ raise TProtocol.TProtocolException(message='Required field accessToken is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.accessToken)
+ value = (value * 31) ^ hash(self.claimsMap)
+ 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)
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.pyc
new file mode 100644
index 0000000..3e304d6
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/security/ttypes.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.pyc
new file mode 100644
index 0000000..d8c5a8c
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__init__.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/__init__.cpython-35.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/__init__.cpython-35.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/__init__.cpython-35.pyc
new file mode 100644
index 0000000..a21b666
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/__init__.cpython-35.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/ttypes.cpython-35.pyc
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/ttypes.cpython-35.pyc b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/ttypes.cpython-35.pyc
new file mode 100644
index 0000000..d58a934
Binary files /dev/null and b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/__pycache__/ttypes.cpython-35.pyc differ
http://git-wip-us.apache.org/repos/asf/airavata-sandbox/blob/2352c0ff/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/constants.py
----------------------------------------------------------------------
diff --git a/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/constants.py b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/constants.py
new file mode 100644
index 0000000..99717a9
--- /dev/null
+++ b/Interacting_with_Airavata_using_ipython_Notebook/Admin-User/apache/airavata/model/status/constants.py
@@ -0,0 +1,11 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+# options string: py
+#
+
+from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from ttypes import *
+