You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/01/12 16:58:29 UTC
[15/65] [abbrv] airavata git commit: renaming the module
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php
deleted file mode 100644
index aa25b92..0000000
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/metadata/Types.php
+++ /dev/null
@@ -1,371 +0,0 @@
-<?php
-namespace Airavata\Model\file\metadata;
-
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-use Thrift\Base\TBase;
-use Thrift\Type\TType;
-use Thrift\Type\TMessageType;
-use Thrift\Exception\TException;
-use Thrift\Exception\TProtocolException;
-use Thrift\Protocol\TProtocol;
-use Thrift\Protocol\TBinaryProtocolAccelerated;
-use Thrift\Exception\TApplicationException;
-
-
-final class MetadataType {
- const FILE = 0;
- const COLLECTION = 1;
- static public $__names = array(
- 0 => 'FILE',
- 1 => 'COLLECTION',
- );
-}
-
-class MetadataModel {
- static $_TSPEC;
-
- /**
- * @var string
- */
- public $metadataId = null;
- /**
- * @var string
- */
- public $gatewayId = null;
- /**
- * @var string
- */
- public $username = null;
- /**
- * @var string[]
- */
- public $sharedUsers = null;
- /**
- * @var bool
- */
- public $sharedPublic = null;
- /**
- * @var string
- */
- public $userFriendlyName = null;
- /**
- * @var string
- */
- public $userFriendlyDescription = null;
- /**
- * @var int
- */
- public $metadataType = null;
- /**
- * @var string
- */
- public $associatedEntityId = null;
- /**
- * @var array
- */
- public $customInformation = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'metadataId',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'gatewayId',
- 'type' => TType::STRING,
- ),
- 3 => array(
- 'var' => 'username',
- 'type' => TType::STRING,
- ),
- 4 => array(
- 'var' => 'sharedUsers',
- 'type' => TType::LST,
- 'etype' => TType::STRING,
- 'elem' => array(
- 'type' => TType::STRING,
- ),
- ),
- 5 => array(
- 'var' => 'sharedPublic',
- 'type' => TType::BOOL,
- ),
- 6 => array(
- 'var' => 'userFriendlyName',
- 'type' => TType::STRING,
- ),
- 7 => array(
- 'var' => 'userFriendlyDescription',
- 'type' => TType::STRING,
- ),
- 8 => array(
- 'var' => 'metadataType',
- 'type' => TType::I32,
- ),
- 9 => array(
- 'var' => 'associatedEntityId',
- 'type' => TType::STRING,
- ),
- 10 => array(
- 'var' => 'customInformation',
- 'type' => TType::MAP,
- 'ktype' => TType::STRING,
- 'vtype' => TType::STRING,
- 'key' => array(
- 'type' => TType::STRING,
- ),
- 'val' => array(
- 'type' => TType::STRING,
- ),
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['metadataId'])) {
- $this->metadataId = $vals['metadataId'];
- }
- if (isset($vals['gatewayId'])) {
- $this->gatewayId = $vals['gatewayId'];
- }
- if (isset($vals['username'])) {
- $this->username = $vals['username'];
- }
- if (isset($vals['sharedUsers'])) {
- $this->sharedUsers = $vals['sharedUsers'];
- }
- if (isset($vals['sharedPublic'])) {
- $this->sharedPublic = $vals['sharedPublic'];
- }
- if (isset($vals['userFriendlyName'])) {
- $this->userFriendlyName = $vals['userFriendlyName'];
- }
- if (isset($vals['userFriendlyDescription'])) {
- $this->userFriendlyDescription = $vals['userFriendlyDescription'];
- }
- if (isset($vals['metadataType'])) {
- $this->metadataType = $vals['metadataType'];
- }
- if (isset($vals['associatedEntityId'])) {
- $this->associatedEntityId = $vals['associatedEntityId'];
- }
- if (isset($vals['customInformation'])) {
- $this->customInformation = $vals['customInformation'];
- }
- }
- }
-
- public function getName() {
- return 'MetadataModel';
- }
-
- public function read($input)
- {
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
- {
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->metadataId);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 2:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->gatewayId);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 3:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->username);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 4:
- if ($ftype == TType::LST) {
- $this->sharedUsers = array();
- $_size0 = 0;
- $_etype3 = 0;
- $xfer += $input->readListBegin($_etype3, $_size0);
- for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
- {
- $elem5 = null;
- $xfer += $input->readString($elem5);
- $this->sharedUsers []= $elem5;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 5:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->sharedPublic);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 6:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->userFriendlyName);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 7:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->userFriendlyDescription);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 8:
- if ($ftype == TType::I32) {
- $xfer += $input->readI32($this->metadataType);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 9:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->associatedEntityId);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 10:
- if ($ftype == TType::MAP) {
- $this->customInformation = array();
- $_size6 = 0;
- $_ktype7 = 0;
- $_vtype8 = 0;
- $xfer += $input->readMapBegin($_ktype7, $_vtype8, $_size6);
- for ($_i10 = 0; $_i10 < $_size6; ++$_i10)
- {
- $key11 = '';
- $val12 = '';
- $xfer += $input->readString($key11);
- $xfer += $input->readString($val12);
- $this->customInformation[$key11] = $val12;
- }
- $xfer += $input->readMapEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('MetadataModel');
- if ($this->metadataId !== null) {
- $xfer += $output->writeFieldBegin('metadataId', TType::STRING, 1);
- $xfer += $output->writeString($this->metadataId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->gatewayId !== null) {
- $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2);
- $xfer += $output->writeString($this->gatewayId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->username !== null) {
- $xfer += $output->writeFieldBegin('username', TType::STRING, 3);
- $xfer += $output->writeString($this->username);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->sharedUsers !== null) {
- if (!is_array($this->sharedUsers)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('sharedUsers', TType::LST, 4);
- {
- $output->writeListBegin(TType::STRING, count($this->sharedUsers));
- {
- foreach ($this->sharedUsers as $iter13)
- {
- $xfer += $output->writeString($iter13);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- if ($this->sharedPublic !== null) {
- $xfer += $output->writeFieldBegin('sharedPublic', TType::BOOL, 5);
- $xfer += $output->writeBool($this->sharedPublic);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->userFriendlyName !== null) {
- $xfer += $output->writeFieldBegin('userFriendlyName', TType::STRING, 6);
- $xfer += $output->writeString($this->userFriendlyName);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->userFriendlyDescription !== null) {
- $xfer += $output->writeFieldBegin('userFriendlyDescription', TType::STRING, 7);
- $xfer += $output->writeString($this->userFriendlyDescription);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->metadataType !== null) {
- $xfer += $output->writeFieldBegin('metadataType', TType::I32, 8);
- $xfer += $output->writeI32($this->metadataType);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->associatedEntityId !== null) {
- $xfer += $output->writeFieldBegin('associatedEntityId', TType::STRING, 9);
- $xfer += $output->writeString($this->associatedEntityId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->customInformation !== null) {
- if (!is_array($this->customInformation)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('customInformation', TType::MAP, 10);
- {
- $output->writeMapBegin(TType::STRING, TType::STRING, count($this->customInformation));
- {
- foreach ($this->customInformation as $kiter14 => $viter15)
- {
- $xfer += $output->writeString($kiter14);
- $xfer += $output->writeString($viter15);
- }
- }
- $output->writeMapEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py
deleted file mode 100644
index e69de29..0000000
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/__init__.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/constants.py
deleted file mode 100644
index 4a6492b..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/constants.py
+++ /dev/null
@@ -1,11 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/ttypes.py
deleted file mode 100644
index b50ac94..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/metadata/ttypes.py
+++ /dev/null
@@ -1,232 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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 MetadataType:
- FILE = 0
- COLLECTION = 1
-
- _VALUES_TO_NAMES = {
- 0: "FILE",
- 1: "COLLECTION",
- }
-
- _NAMES_TO_VALUES = {
- "FILE": 0,
- "COLLECTION": 1,
- }
-
-
-class MetadataModel:
- """
- Attributes:
- - metadataId
- - gatewayId
- - username
- - sharedUsers
- - sharedPublic
- - userFriendlyName
- - userFriendlyDescription
- - metadataType
- - associatedEntityId
- - customInformation
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'metadataId', None, None, ), # 1
- (2, TType.STRING, 'gatewayId', None, None, ), # 2
- (3, TType.STRING, 'username', None, None, ), # 3
- (4, TType.LIST, 'sharedUsers', (TType.STRING,None), None, ), # 4
- (5, TType.BOOL, 'sharedPublic', None, None, ), # 5
- (6, TType.STRING, 'userFriendlyName', None, None, ), # 6
- (7, TType.STRING, 'userFriendlyDescription', None, None, ), # 7
- (8, TType.I32, 'metadataType', None, None, ), # 8
- (9, TType.STRING, 'associatedEntityId', None, None, ), # 9
- (10, TType.MAP, 'customInformation', (TType.STRING,None,TType.STRING,None), None, ), # 10
- )
-
- def __init__(self, metadataId=None, gatewayId=None, username=None, sharedUsers=None, sharedPublic=None, userFriendlyName=None, userFriendlyDescription=None, metadataType=None, associatedEntityId=None, customInformation=None,):
- self.metadataId = metadataId
- self.gatewayId = gatewayId
- self.username = username
- self.sharedUsers = sharedUsers
- self.sharedPublic = sharedPublic
- self.userFriendlyName = userFriendlyName
- self.userFriendlyDescription = userFriendlyDescription
- self.metadataType = metadataType
- self.associatedEntityId = associatedEntityId
- self.customInformation = customInformation
-
- 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.metadataId = 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.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.sharedUsers = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString()
- self.sharedUsers.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.sharedPublic = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.userFriendlyName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.userFriendlyDescription = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I32:
- self.metadataType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.STRING:
- self.associatedEntityId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.MAP:
- self.customInformation = {}
- (_ktype7, _vtype8, _size6 ) = iprot.readMapBegin()
- for _i10 in xrange(_size6):
- _key11 = iprot.readString()
- _val12 = iprot.readString()
- self.customInformation[_key11] = _val12
- 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('MetadataModel')
- if self.metadataId is not None:
- oprot.writeFieldBegin('metadataId', TType.STRING, 1)
- oprot.writeString(self.metadataId)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 3)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.sharedUsers is not None:
- oprot.writeFieldBegin('sharedUsers', TType.LIST, 4)
- oprot.writeListBegin(TType.STRING, len(self.sharedUsers))
- for iter13 in self.sharedUsers:
- oprot.writeString(iter13)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.sharedPublic is not None:
- oprot.writeFieldBegin('sharedPublic', TType.BOOL, 5)
- oprot.writeBool(self.sharedPublic)
- oprot.writeFieldEnd()
- if self.userFriendlyName is not None:
- oprot.writeFieldBegin('userFriendlyName', TType.STRING, 6)
- oprot.writeString(self.userFriendlyName)
- oprot.writeFieldEnd()
- if self.userFriendlyDescription is not None:
- oprot.writeFieldBegin('userFriendlyDescription', TType.STRING, 7)
- oprot.writeString(self.userFriendlyDescription)
- oprot.writeFieldEnd()
- if self.metadataType is not None:
- oprot.writeFieldBegin('metadataType', TType.I32, 8)
- oprot.writeI32(self.metadataType)
- oprot.writeFieldEnd()
- if self.associatedEntityId is not None:
- oprot.writeFieldBegin('associatedEntityId', TType.STRING, 9)
- oprot.writeString(self.associatedEntityId)
- oprot.writeFieldEnd()
- if self.customInformation is not None:
- oprot.writeFieldBegin('customInformation', TType.MAP, 10)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.customInformation))
- for kiter14,viter15 in self.customInformation.items():
- oprot.writeString(kiter14)
- oprot.writeString(viter15)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.metadataId)
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.sharedUsers)
- value = (value * 31) ^ hash(self.sharedPublic)
- value = (value * 31) ^ hash(self.userFriendlyName)
- value = (value * 31) ^ hash(self.userFriendlyDescription)
- value = (value * 31) ^ hash(self.metadataType)
- value = (value * 31) ^ hash(self.associatedEntityId)
- value = (value * 31) ^ hash(self.customInformation)
- 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/__init__.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/constants.py
deleted file mode 100644
index 4a6492b..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/constants.py
+++ /dev/null
@@ -1,11 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/ttypes.py
deleted file mode 100644
index df2ddf5..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/replica/ttypes.py
+++ /dev/null
@@ -1,663 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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.data.movement.ttypes
-
-
-from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class FileModelType:
- FILE = 0
- DIRECTORY = 1
-
- _VALUES_TO_NAMES = {
- 0: "FILE",
- 1: "DIRECTORY",
- }
-
- _NAMES_TO_VALUES = {
- "FILE": 0,
- "DIRECTORY": 1,
- }
-
-class StorageResourceType:
- GATEWAY_DATA_STORE = 0
- BACKUP_GATEWAY_DATA_STORE = 1
- COMPUTE_RESOURCE = 2
- LONG_TERM_STORAGE_RESOURCE = 3
- OTHER = 4
-
- _VALUES_TO_NAMES = {
- 0: "GATEWAY_DATA_STORE",
- 1: "BACKUP_GATEWAY_DATA_STORE",
- 2: "COMPUTE_RESOURCE",
- 3: "LONG_TERM_STORAGE_RESOURCE",
- 4: "OTHER",
- }
-
- _NAMES_TO_VALUES = {
- "GATEWAY_DATA_STORE": 0,
- "BACKUP_GATEWAY_DATA_STORE": 1,
- "COMPUTE_RESOURCE": 2,
- "LONG_TERM_STORAGE_RESOURCE": 3,
- "OTHER": 4,
- }
-
-class ReplicaPersistentType:
- TRANSIENT = 0
- PERSISTENT = 1
-
- _VALUES_TO_NAMES = {
- 0: "TRANSIENT",
- 1: "PERSISTENT",
- }
-
- _NAMES_TO_VALUES = {
- "TRANSIENT": 0,
- "PERSISTENT": 1,
- }
-
-
-class FileCollectionModel:
- """
- Attributes:
- - collectionId
- - gatewayId
- - username
- - sharedUsers
- - sharedPublic
- - collectionName
- - collectionDescription
- - fileIdList
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'collectionId', None, None, ), # 1
- (2, TType.STRING, 'gatewayId', None, None, ), # 2
- (3, TType.STRING, 'username', None, None, ), # 3
- (4, TType.LIST, 'sharedUsers', (TType.STRING,None), None, ), # 4
- (5, TType.BOOL, 'sharedPublic', None, None, ), # 5
- (6, TType.STRING, 'collectionName', None, None, ), # 6
- (7, TType.STRING, 'collectionDescription', None, None, ), # 7
- (8, TType.LIST, 'fileIdList', (TType.STRING,None), None, ), # 8
- )
-
- def __init__(self, collectionId=None, gatewayId=None, username=None, sharedUsers=None, sharedPublic=None, collectionName=None, collectionDescription=None, fileIdList=None,):
- self.collectionId = collectionId
- self.gatewayId = gatewayId
- self.username = username
- self.sharedUsers = sharedUsers
- self.sharedPublic = sharedPublic
- self.collectionName = collectionName
- self.collectionDescription = collectionDescription
- self.fileIdList = fileIdList
-
- 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.collectionId = 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.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.sharedUsers = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString()
- self.sharedUsers.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.sharedPublic = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.collectionName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.collectionDescription = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.LIST:
- self.fileIdList = []
- (_etype9, _size6) = iprot.readListBegin()
- for _i10 in xrange(_size6):
- _elem11 = iprot.readString()
- self.fileIdList.append(_elem11)
- 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('FileCollectionModel')
- if self.collectionId is not None:
- oprot.writeFieldBegin('collectionId', TType.STRING, 1)
- oprot.writeString(self.collectionId)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 3)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.sharedUsers is not None:
- oprot.writeFieldBegin('sharedUsers', TType.LIST, 4)
- oprot.writeListBegin(TType.STRING, len(self.sharedUsers))
- for iter12 in self.sharedUsers:
- oprot.writeString(iter12)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.sharedPublic is not None:
- oprot.writeFieldBegin('sharedPublic', TType.BOOL, 5)
- oprot.writeBool(self.sharedPublic)
- oprot.writeFieldEnd()
- if self.collectionName is not None:
- oprot.writeFieldBegin('collectionName', TType.STRING, 6)
- oprot.writeString(self.collectionName)
- oprot.writeFieldEnd()
- if self.collectionDescription is not None:
- oprot.writeFieldBegin('collectionDescription', TType.STRING, 7)
- oprot.writeString(self.collectionDescription)
- oprot.writeFieldEnd()
- if self.fileIdList is not None:
- oprot.writeFieldBegin('fileIdList', TType.LIST, 8)
- oprot.writeListBegin(TType.STRING, len(self.fileIdList))
- for iter13 in self.fileIdList:
- oprot.writeString(iter13)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.collectionId)
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.sharedUsers)
- value = (value * 31) ^ hash(self.sharedPublic)
- value = (value * 31) ^ hash(self.collectionName)
- value = (value * 31) ^ hash(self.collectionDescription)
- value = (value * 31) ^ hash(self.fileIdList)
- 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 FileModel:
- """
- Attributes:
- - fileId
- - gatewayId
- - username
- - sharedUsers
- - sharedPublic
- - fileName
- - fileDescription
- - sha256Checksum
- - fileType
- - fileSize
- - dataType
- - creationTime
- - lastModifiedTime
- - fileReplicas
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'fileId', None, None, ), # 1
- (2, TType.STRING, 'gatewayId', None, None, ), # 2
- (3, TType.STRING, 'username', None, None, ), # 3
- (4, TType.LIST, 'sharedUsers', (TType.STRING,None), None, ), # 4
- (5, TType.BOOL, 'sharedPublic', None, None, ), # 5
- (6, TType.STRING, 'fileName', None, None, ), # 6
- (7, TType.STRING, 'fileDescription', None, None, ), # 7
- (8, TType.STRING, 'sha256Checksum', None, None, ), # 8
- (9, TType.I32, 'fileType', None, None, ), # 9
- (10, TType.I32, 'fileSize', None, None, ), # 10
- (11, TType.STRING, 'dataType', None, None, ), # 11
- (12, TType.I64, 'creationTime', None, None, ), # 12
- (13, TType.I64, 'lastModifiedTime', None, None, ), # 13
- (14, TType.LIST, 'fileReplicas', (TType.STRUCT,(FileReplicaModel, FileReplicaModel.thrift_spec)), None, ), # 14
- )
-
- def __init__(self, fileId=None, gatewayId=None, username=None, sharedUsers=None, sharedPublic=None, fileName=None, fileDescription=None, sha256Checksum=None, fileType=None, fileSize=None, dataType=None, creationTime=None, lastModifiedTime=None, fileReplicas=None,):
- self.fileId = fileId
- self.gatewayId = gatewayId
- self.username = username
- self.sharedUsers = sharedUsers
- self.sharedPublic = sharedPublic
- self.fileName = fileName
- self.fileDescription = fileDescription
- self.sha256Checksum = sha256Checksum
- self.fileType = fileType
- self.fileSize = fileSize
- self.dataType = dataType
- self.creationTime = creationTime
- self.lastModifiedTime = lastModifiedTime
- self.fileReplicas = fileReplicas
-
- 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.fileId = 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.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.LIST:
- self.sharedUsers = []
- (_etype17, _size14) = iprot.readListBegin()
- for _i18 in xrange(_size14):
- _elem19 = iprot.readString()
- self.sharedUsers.append(_elem19)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.sharedPublic = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.fileName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.fileDescription = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.sha256Checksum = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I32:
- self.fileType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.I32:
- self.fileSize = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.dataType = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 13:
- if ftype == TType.I64:
- self.lastModifiedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 14:
- if ftype == TType.LIST:
- self.fileReplicas = []
- (_etype23, _size20) = iprot.readListBegin()
- for _i24 in xrange(_size20):
- _elem25 = FileReplicaModel()
- _elem25.read(iprot)
- self.fileReplicas.append(_elem25)
- 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('FileModel')
- if self.fileId is not None:
- oprot.writeFieldBegin('fileId', TType.STRING, 1)
- oprot.writeString(self.fileId)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 3)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.sharedUsers is not None:
- oprot.writeFieldBegin('sharedUsers', TType.LIST, 4)
- oprot.writeListBegin(TType.STRING, len(self.sharedUsers))
- for iter26 in self.sharedUsers:
- oprot.writeString(iter26)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.sharedPublic is not None:
- oprot.writeFieldBegin('sharedPublic', TType.BOOL, 5)
- oprot.writeBool(self.sharedPublic)
- oprot.writeFieldEnd()
- if self.fileName is not None:
- oprot.writeFieldBegin('fileName', TType.STRING, 6)
- oprot.writeString(self.fileName)
- oprot.writeFieldEnd()
- if self.fileDescription is not None:
- oprot.writeFieldBegin('fileDescription', TType.STRING, 7)
- oprot.writeString(self.fileDescription)
- oprot.writeFieldEnd()
- if self.sha256Checksum is not None:
- oprot.writeFieldBegin('sha256Checksum', TType.STRING, 8)
- oprot.writeString(self.sha256Checksum)
- oprot.writeFieldEnd()
- if self.fileType is not None:
- oprot.writeFieldBegin('fileType', TType.I32, 9)
- oprot.writeI32(self.fileType)
- oprot.writeFieldEnd()
- if self.fileSize is not None:
- oprot.writeFieldBegin('fileSize', TType.I32, 10)
- oprot.writeI32(self.fileSize)
- oprot.writeFieldEnd()
- if self.dataType is not None:
- oprot.writeFieldBegin('dataType', TType.STRING, 11)
- oprot.writeString(self.dataType)
- oprot.writeFieldEnd()
- if self.creationTime is not None:
- oprot.writeFieldBegin('creationTime', TType.I64, 12)
- oprot.writeI64(self.creationTime)
- oprot.writeFieldEnd()
- if self.lastModifiedTime is not None:
- oprot.writeFieldBegin('lastModifiedTime', TType.I64, 13)
- oprot.writeI64(self.lastModifiedTime)
- oprot.writeFieldEnd()
- if self.fileReplicas is not None:
- oprot.writeFieldBegin('fileReplicas', TType.LIST, 14)
- oprot.writeListBegin(TType.STRUCT, len(self.fileReplicas))
- for iter27 in self.fileReplicas:
- iter27.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.fileId)
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.sharedUsers)
- value = (value * 31) ^ hash(self.sharedPublic)
- value = (value * 31) ^ hash(self.fileName)
- value = (value * 31) ^ hash(self.fileDescription)
- value = (value * 31) ^ hash(self.sha256Checksum)
- value = (value * 31) ^ hash(self.fileType)
- value = (value * 31) ^ hash(self.fileSize)
- value = (value * 31) ^ hash(self.dataType)
- value = (value * 31) ^ hash(self.creationTime)
- value = (value * 31) ^ hash(self.lastModifiedTime)
- value = (value * 31) ^ hash(self.fileReplicas)
- 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 FileReplicaModel:
- """
- Attributes:
- - replicaName
- - replicaDescription
- - storageHostname
- - storageResourceId
- - filePath
- - creationTime
- - validUntilTime
- - storageResourceType
- - replicaPersistentType
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'replicaName', None, None, ), # 1
- (2, TType.STRING, 'replicaDescription', None, None, ), # 2
- (3, TType.STRING, 'storageHostname', None, None, ), # 3
- (4, TType.STRING, 'storageResourceId', None, None, ), # 4
- (5, TType.STRING, 'filePath', None, None, ), # 5
- (6, TType.I64, 'creationTime', None, None, ), # 6
- (7, TType.I64, 'validUntilTime', None, None, ), # 7
- (8, TType.I32, 'storageResourceType', None, None, ), # 8
- (9, TType.I32, 'replicaPersistentType', None, None, ), # 9
- )
-
- def __init__(self, replicaName=None, replicaDescription=None, storageHostname=None, storageResourceId=None, filePath=None, creationTime=None, validUntilTime=None, storageResourceType=None, replicaPersistentType=None,):
- self.replicaName = replicaName
- self.replicaDescription = replicaDescription
- self.storageHostname = storageHostname
- self.storageResourceId = storageResourceId
- self.filePath = filePath
- self.creationTime = creationTime
- self.validUntilTime = validUntilTime
- self.storageResourceType = storageResourceType
- self.replicaPersistentType = replicaPersistentType
-
- 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.replicaName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.replicaDescription = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.storageHostname = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.storageResourceId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.filePath = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I64:
- self.validUntilTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I32:
- self.storageResourceType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I32:
- self.replicaPersistentType = 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('FileReplicaModel')
- if self.replicaName is not None:
- oprot.writeFieldBegin('replicaName', TType.STRING, 1)
- oprot.writeString(self.replicaName)
- oprot.writeFieldEnd()
- if self.replicaDescription is not None:
- oprot.writeFieldBegin('replicaDescription', TType.STRING, 2)
- oprot.writeString(self.replicaDescription)
- oprot.writeFieldEnd()
- if self.storageHostname is not None:
- oprot.writeFieldBegin('storageHostname', TType.STRING, 3)
- oprot.writeString(self.storageHostname)
- oprot.writeFieldEnd()
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 4)
- oprot.writeString(self.storageResourceId)
- oprot.writeFieldEnd()
- if self.filePath is not None:
- oprot.writeFieldBegin('filePath', TType.STRING, 5)
- oprot.writeString(self.filePath)
- oprot.writeFieldEnd()
- if self.creationTime is not None:
- oprot.writeFieldBegin('creationTime', TType.I64, 6)
- oprot.writeI64(self.creationTime)
- oprot.writeFieldEnd()
- if self.validUntilTime is not None:
- oprot.writeFieldBegin('validUntilTime', TType.I64, 7)
- oprot.writeI64(self.validUntilTime)
- oprot.writeFieldEnd()
- if self.storageResourceType is not None:
- oprot.writeFieldBegin('storageResourceType', TType.I32, 8)
- oprot.writeI32(self.storageResourceType)
- oprot.writeFieldEnd()
- if self.replicaPersistentType is not None:
- oprot.writeFieldBegin('replicaPersistentType', TType.I32, 9)
- oprot.writeI32(self.replicaPersistentType)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.replicaName)
- value = (value * 31) ^ hash(self.replicaDescription)
- value = (value * 31) ^ hash(self.storageHostname)
- value = (value * 31) ^ hash(self.storageResourceId)
- value = (value * 31) ^ hash(self.filePath)
- value = (value * 31) ^ hash(self.creationTime)
- value = (value * 31) ^ hash(self.validUntilTime)
- value = (value * 31) ^ hash(self.storageResourceType)
- value = (value * 31) ^ hash(self.replicaPersistentType)
- 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/__init__.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/constants.py
deleted file mode 100644
index 4a6492b..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/constants.py
+++ /dev/null
@@ -1,11 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/ttypes.py
deleted file mode 100644
index ae35462..0000000
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/transfer/ttypes.py
+++ /dev/null
@@ -1,597 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# 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 StorageResourceProtocol:
- SCP = 0
- SFTP = 1
- HTTP = 2
- HTTPS = 3
- GridFTP = 4
- LOCAL = 5
-
- _VALUES_TO_NAMES = {
- 0: "SCP",
- 1: "SFTP",
- 2: "HTTP",
- 3: "HTTPS",
- 4: "GridFTP",
- 5: "LOCAL",
- }
-
- _NAMES_TO_VALUES = {
- "SCP": 0,
- "SFTP": 1,
- "HTTP": 2,
- "HTTPS": 3,
- "GridFTP": 4,
- "LOCAL": 5,
- }
-
-class LSEntryType:
- DIRECTORY = 0
- FILE = 1
-
- _VALUES_TO_NAMES = {
- 0: "DIRECTORY",
- 1: "FILE",
- }
-
- _NAMES_TO_VALUES = {
- "DIRECTORY": 0,
- "FILE": 1,
- }
-
-class FileTransferMode:
- SYNC = 0
- ASYNC = 1
-
- _VALUES_TO_NAMES = {
- 0: "SYNC",
- 1: "ASYNC",
- }
-
- _NAMES_TO_VALUES = {
- "SYNC": 0,
- "ASYNC": 1,
- }
-
-class FileTransferStatus:
- CREATED = 0
- QUEUED = 1
- RUNNING = 2
- COMPLETED = 3
- FAILED = 4
-
- _VALUES_TO_NAMES = {
- 0: "CREATED",
- 1: "QUEUED",
- 2: "RUNNING",
- 3: "COMPLETED",
- 4: "FAILED",
- }
-
- _NAMES_TO_VALUES = {
- "CREATED": 0,
- "QUEUED": 1,
- "RUNNING": 2,
- "COMPLETED": 3,
- "FAILED": 4,
- }
-
-
-class FileTransferRequestModel:
- """
- Attributes:
- - transferId
- - gatewayId
- - username
- - srcHostname
- - srcLoginName
- - srcPort
- - srcProtocol
- - srcFilePath
- - srcHostCredToken
- - destHostname
- - destLoginName
- - destPort
- - destProtocol
- - destFilePath
- - destHostCredToken
- - fileTransferMode
- - transferStatus
- - fileSize
- - transferTime
- - createdTime
- - lastModifiedType
- - callbackEmails
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'transferId', None, None, ), # 1
- (2, TType.STRING, 'gatewayId', None, None, ), # 2
- (3, TType.STRING, 'username', None, None, ), # 3
- (4, TType.STRING, 'srcHostname', None, None, ), # 4
- (5, TType.STRING, 'srcLoginName', None, None, ), # 5
- (6, TType.I64, 'srcPort', None, None, ), # 6
- (7, TType.I32, 'srcProtocol', None, None, ), # 7
- (8, TType.STRING, 'srcFilePath', None, None, ), # 8
- (9, TType.STRING, 'srcHostCredToken', None, None, ), # 9
- (10, TType.STRING, 'destHostname', None, None, ), # 10
- (11, TType.STRING, 'destLoginName', None, None, ), # 11
- (12, TType.I64, 'destPort', None, None, ), # 12
- (13, TType.I32, 'destProtocol', None, None, ), # 13
- (14, TType.STRING, 'destFilePath', None, None, ), # 14
- (15, TType.STRING, 'destHostCredToken', None, None, ), # 15
- (16, TType.I32, 'fileTransferMode', None, None, ), # 16
- (17, TType.I32, 'transferStatus', None, None, ), # 17
- (18, TType.I64, 'fileSize', None, None, ), # 18
- (19, TType.I64, 'transferTime', None, None, ), # 19
- (20, TType.I64, 'createdTime', None, None, ), # 20
- (21, TType.I64, 'lastModifiedType', None, None, ), # 21
- (22, TType.LIST, 'callbackEmails', (TType.STRING,None), None, ), # 22
- )
-
- def __init__(self, transferId=None, gatewayId=None, username=None, srcHostname=None, srcLoginName=None, srcPort=None, srcProtocol=None, srcFilePath=None, srcHostCredToken=None, destHostname=None, destLoginName=None, destPort=None, destProtocol=None, destFilePath=None, destHostCredToken=None, fileTransferMode=None, transferStatus=None, fileSize=None, transferTime=None, createdTime=None, lastModifiedType=None, callbackEmails=None,):
- self.transferId = transferId
- self.gatewayId = gatewayId
- self.username = username
- self.srcHostname = srcHostname
- self.srcLoginName = srcLoginName
- self.srcPort = srcPort
- self.srcProtocol = srcProtocol
- self.srcFilePath = srcFilePath
- self.srcHostCredToken = srcHostCredToken
- self.destHostname = destHostname
- self.destLoginName = destLoginName
- self.destPort = destPort
- self.destProtocol = destProtocol
- self.destFilePath = destFilePath
- self.destHostCredToken = destHostCredToken
- self.fileTransferMode = fileTransferMode
- self.transferStatus = transferStatus
- self.fileSize = fileSize
- self.transferTime = transferTime
- self.createdTime = createdTime
- self.lastModifiedType = lastModifiedType
- self.callbackEmails = callbackEmails
-
- 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.transferId = 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.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.srcHostname = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.srcLoginName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I64:
- self.srcPort = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.srcProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.srcFilePath = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.STRING:
- self.srcHostCredToken = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.STRING:
- self.destHostname = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.destLoginName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.I64:
- self.destPort = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 13:
- if ftype == TType.I32:
- self.destProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 14:
- if ftype == TType.STRING:
- self.destFilePath = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 15:
- if ftype == TType.STRING:
- self.destHostCredToken = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 16:
- if ftype == TType.I32:
- self.fileTransferMode = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 17:
- if ftype == TType.I32:
- self.transferStatus = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 18:
- if ftype == TType.I64:
- self.fileSize = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 19:
- if ftype == TType.I64:
- self.transferTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 20:
- if ftype == TType.I64:
- self.createdTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 21:
- if ftype == TType.I64:
- self.lastModifiedType = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 22:
- if ftype == TType.LIST:
- self.callbackEmails = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString()
- self.callbackEmails.append(_elem5)
- 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('FileTransferRequestModel')
- if self.transferId is not None:
- oprot.writeFieldBegin('transferId', TType.STRING, 1)
- oprot.writeString(self.transferId)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 3)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.srcHostname is not None:
- oprot.writeFieldBegin('srcHostname', TType.STRING, 4)
- oprot.writeString(self.srcHostname)
- oprot.writeFieldEnd()
- if self.srcLoginName is not None:
- oprot.writeFieldBegin('srcLoginName', TType.STRING, 5)
- oprot.writeString(self.srcLoginName)
- oprot.writeFieldEnd()
- if self.srcPort is not None:
- oprot.writeFieldBegin('srcPort', TType.I64, 6)
- oprot.writeI64(self.srcPort)
- oprot.writeFieldEnd()
- if self.srcProtocol is not None:
- oprot.writeFieldBegin('srcProtocol', TType.I32, 7)
- oprot.writeI32(self.srcProtocol)
- oprot.writeFieldEnd()
- if self.srcFilePath is not None:
- oprot.writeFieldBegin('srcFilePath', TType.STRING, 8)
- oprot.writeString(self.srcFilePath)
- oprot.writeFieldEnd()
- if self.srcHostCredToken is not None:
- oprot.writeFieldBegin('srcHostCredToken', TType.STRING, 9)
- oprot.writeString(self.srcHostCredToken)
- oprot.writeFieldEnd()
- if self.destHostname is not None:
- oprot.writeFieldBegin('destHostname', TType.STRING, 10)
- oprot.writeString(self.destHostname)
- oprot.writeFieldEnd()
- if self.destLoginName is not None:
- oprot.writeFieldBegin('destLoginName', TType.STRING, 11)
- oprot.writeString(self.destLoginName)
- oprot.writeFieldEnd()
- if self.destPort is not None:
- oprot.writeFieldBegin('destPort', TType.I64, 12)
- oprot.writeI64(self.destPort)
- oprot.writeFieldEnd()
- if self.destProtocol is not None:
- oprot.writeFieldBegin('destProtocol', TType.I32, 13)
- oprot.writeI32(self.destProtocol)
- oprot.writeFieldEnd()
- if self.destFilePath is not None:
- oprot.writeFieldBegin('destFilePath', TType.STRING, 14)
- oprot.writeString(self.destFilePath)
- oprot.writeFieldEnd()
- if self.destHostCredToken is not None:
- oprot.writeFieldBegin('destHostCredToken', TType.STRING, 15)
- oprot.writeString(self.destHostCredToken)
- oprot.writeFieldEnd()
- if self.fileTransferMode is not None:
- oprot.writeFieldBegin('fileTransferMode', TType.I32, 16)
- oprot.writeI32(self.fileTransferMode)
- oprot.writeFieldEnd()
- if self.transferStatus is not None:
- oprot.writeFieldBegin('transferStatus', TType.I32, 17)
- oprot.writeI32(self.transferStatus)
- oprot.writeFieldEnd()
- if self.fileSize is not None:
- oprot.writeFieldBegin('fileSize', TType.I64, 18)
- oprot.writeI64(self.fileSize)
- oprot.writeFieldEnd()
- if self.transferTime is not None:
- oprot.writeFieldBegin('transferTime', TType.I64, 19)
- oprot.writeI64(self.transferTime)
- oprot.writeFieldEnd()
- if self.createdTime is not None:
- oprot.writeFieldBegin('createdTime', TType.I64, 20)
- oprot.writeI64(self.createdTime)
- oprot.writeFieldEnd()
- if self.lastModifiedType is not None:
- oprot.writeFieldBegin('lastModifiedType', TType.I64, 21)
- oprot.writeI64(self.lastModifiedType)
- oprot.writeFieldEnd()
- if self.callbackEmails is not None:
- oprot.writeFieldBegin('callbackEmails', TType.LIST, 22)
- oprot.writeListBegin(TType.STRING, len(self.callbackEmails))
- for iter6 in self.callbackEmails:
- oprot.writeString(iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.transferId)
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.srcHostname)
- value = (value * 31) ^ hash(self.srcLoginName)
- value = (value * 31) ^ hash(self.srcPort)
- value = (value * 31) ^ hash(self.srcProtocol)
- value = (value * 31) ^ hash(self.srcFilePath)
- value = (value * 31) ^ hash(self.srcHostCredToken)
- value = (value * 31) ^ hash(self.destHostname)
- value = (value * 31) ^ hash(self.destLoginName)
- value = (value * 31) ^ hash(self.destPort)
- value = (value * 31) ^ hash(self.destProtocol)
- value = (value * 31) ^ hash(self.destFilePath)
- value = (value * 31) ^ hash(self.destHostCredToken)
- value = (value * 31) ^ hash(self.fileTransferMode)
- value = (value * 31) ^ hash(self.transferStatus)
- value = (value * 31) ^ hash(self.fileSize)
- value = (value * 31) ^ hash(self.transferTime)
- value = (value * 31) ^ hash(self.createdTime)
- value = (value * 31) ^ hash(self.lastModifiedType)
- value = (value * 31) ^ hash(self.callbackEmails)
- 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 LSEntryModel:
- """
- Attributes:
- - type
- - size
- - nativeType
- - name
- - path
- - storageHostName
- - lastModifiedType
- - createdTime
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'type', None, None, ), # 1
- (2, TType.I64, 'size', None, None, ), # 2
- (3, TType.STRING, 'nativeType', None, None, ), # 3
- (4, TType.STRING, 'name', None, None, ), # 4
- (5, TType.STRING, 'path', None, None, ), # 5
- (6, TType.STRING, 'storageHostName', None, None, ), # 6
- (7, TType.I64, 'lastModifiedType', None, None, ), # 7
- (8, TType.I64, 'createdTime', None, None, ), # 8
- )
-
- def __init__(self, type=None, size=None, nativeType=None, name=None, path=None, storageHostName=None, lastModifiedType=None, createdTime=None,):
- self.type = type
- self.size = size
- self.nativeType = nativeType
- self.name = name
- self.path = path
- self.storageHostName = storageHostName
- self.lastModifiedType = lastModifiedType
- self.createdTime = createdTime
-
- 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.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.size = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.nativeType = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.path = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.storageHostName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I64:
- self.lastModifiedType = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I64:
- self.createdTime = 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('LSEntryModel')
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 1)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.size is not None:
- oprot.writeFieldBegin('size', TType.I64, 2)
- oprot.writeI64(self.size)
- oprot.writeFieldEnd()
- if self.nativeType is not None:
- oprot.writeFieldBegin('nativeType', TType.STRING, 3)
- oprot.writeString(self.nativeType)
- oprot.writeFieldEnd()
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 4)
- oprot.writeString(self.name)
- oprot.writeFieldEnd()
- if self.path is not None:
- oprot.writeFieldBegin('path', TType.STRING, 5)
- oprot.writeString(self.path)
- oprot.writeFieldEnd()
- if self.storageHostName is not None:
- oprot.writeFieldBegin('storageHostName', TType.STRING, 6)
- oprot.writeString(self.storageHostName)
- oprot.writeFieldEnd()
- if self.lastModifiedType is not None:
- oprot.writeFieldBegin('lastModifiedType', TType.I64, 7)
- oprot.writeI64(self.lastModifiedType)
- oprot.writeFieldEnd()
- if self.createdTime is not None:
- oprot.writeFieldBegin('createdTime', TType.I64, 8)
- oprot.writeI64(self.createdTime)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.type)
- value = (value * 31) ^ hash(self.size)
- value = (value * 31) ^ hash(self.nativeType)
- value = (value * 31) ^ hash(self.name)
- value = (value * 31) ^ hash(self.path)
- value = (value * 31) ^ hash(self.storageHostName)
- value = (value * 31) ^ hash(self.lastModifiedType)
- value = (value * 31) ^ hash(self.createdTime)
- 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/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py
index ddb7404..7ed9998 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py
@@ -19,9 +19,9 @@ import apache.airavata.model.process.ttypes
import apache.airavata.model.scheduling.ttypes
import apache.airavata.model.status.ttypes
import apache.airavata.model.data.movement.ttypes
-import apache.airavata.model.file.replica.ttypes
-import apache.airavata.model.file.transfer.ttypes
-import apache.airavata.model.file.metadata.ttypes
+import apache.airavata.model.data.replica.ttypes
+import apache.airavata.model.data.transfer.ttypes
+import apache.airavata.model.data.metadata.ttypes
from thrift.transport import TTransport
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/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
index 912eb2d..eed0531 100644
--- 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
@@ -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 = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
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");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java
index 583fb0e..e65f18a 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java
@@ -77,7 +77,7 @@ import org.slf4j.LoggerFactory;
* assigns to the environment variable "NAME" the value
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class ApplicationDeploymentDescription implements org.apache.thrift.TBase<ApplicationDeploymentDescription, ApplicationDeploymentDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationDeploymentDescription> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationDeploymentDescription");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java
index 02eb6d6..1692a20 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java
@@ -66,7 +66,7 @@ import org.slf4j.LoggerFactory;
* Descriprion of the Module
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class ApplicationModule implements org.apache.thrift.TBase<ApplicationModule, ApplicationModule._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationModule> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationModule");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java
index eef9023..6982392 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java
@@ -60,7 +60,7 @@ import org.slf4j.LoggerFactory;
* commandOrder:
* Order of the command in the multiple command situation
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class CommandObject implements org.apache.thrift.TBase<CommandObject, CommandObject._Fields>, java.io.Serializable, Cloneable, Comparable<CommandObject> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommandObject");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java
index df4bfbe..7de029e 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java
@@ -63,7 +63,7 @@ import org.slf4j.LoggerFactory;
* envPathOrder:
* The order of the setting of the env variables when there are multiple env variables
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class SetEnvPaths implements org.apache.thrift.TBase<SetEnvPaths, SetEnvPaths._Fields>, java.io.Serializable, Cloneable, Comparable<SetEnvPaths> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SetEnvPaths");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java
index 0833f0a..ce41c9e 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appinterface/ApplicationInterfaceDescription.java
@@ -64,7 +64,7 @@ import org.slf4j.LoggerFactory;
* Outputs generated from the application
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class ApplicationInterfaceDescription implements org.apache.thrift.TBase<ApplicationInterfaceDescription, ApplicationInterfaceDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationInterfaceDescription> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationInterfaceDescription");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java
index f9e3b15..99370ff 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/BatchQueue.java
@@ -57,7 +57,7 @@ import org.slf4j.LoggerFactory;
* maxRunTime:
* Maximum allowed run time in hours.
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class BatchQueue implements org.apache.thrift.TBase<BatchQueue, BatchQueue._Fields>, java.io.Serializable, Cloneable, Comparable<BatchQueue> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BatchQueue");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java
index c3a86c9..29be8fc 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/CloudJobSubmission.java
@@ -56,7 +56,7 @@ import org.slf4j.LoggerFactory;
*
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class CloudJobSubmission implements org.apache.thrift.TBase<CloudJobSubmission, CloudJobSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<CloudJobSubmission> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CloudJobSubmission");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java
index 8297934..305ba02 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/ComputeResourceDescription.java
@@ -80,7 +80,7 @@ import org.slf4j.LoggerFactory;
* Map of file systems type and the path.
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class ComputeResourceDescription implements org.apache.thrift.TBase<ComputeResourceDescription, ComputeResourceDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ComputeResourceDescription> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComputeResourceDescription");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java
index c8f6d3f..29b4e8e 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/GlobusJobSubmission.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 = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class GlobusJobSubmission implements org.apache.thrift.TBase<GlobusJobSubmission, GlobusJobSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<GlobusJobSubmission> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GlobusJobSubmission");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java
index cbfaf6d..2e7b688 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/JobSubmissionInterface.java
@@ -61,7 +61,7 @@ import org.slf4j.LoggerFactory;
* Lower the numerical number, higher the priority
*
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class JobSubmissionInterface implements org.apache.thrift.TBase<JobSubmissionInterface, JobSubmissionInterface._Fields>, java.io.Serializable, Cloneable, Comparable<JobSubmissionInterface> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobSubmissionInterface");
http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java
index a1f7e03..5ef3389 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/computeresource/LOCALSubmission.java
@@ -60,7 +60,7 @@ import org.slf4j.LoggerFactory;
* sshPort:
* If a non-default port needs to used, specify it.
*/
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12")
public class LOCALSubmission implements org.apache.thrift.TBase<LOCALSubmission, LOCALSubmission._Fields>, java.io.Serializable, Cloneable, Comparable<LOCALSubmission> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LOCALSubmission");