Fix typo in firewall driver attribute name

* firewall driver attribute name 'security_group' was changed
  to 'security_groups' in data migration
* names of appropriate functions were also changed

Change-Id: Ie8d5faed47e01ee7b5685104419abbd14853622f
Closes-Bug: #1644820
This commit is contained in:
Anastasiya 2016-11-25 16:07:57 +03:00
parent 64994371cd
commit 42e982ed40
4 changed files with 23 additions and 23 deletions

View File

@ -140,7 +140,7 @@ CA_FILE = {
}]
}
SECURITY_GROUP = {
SECURITY_GROUPS = {
'value': 'iptables_hybrid',
'values': [
{
@ -233,7 +233,7 @@ DEFAULT_RELEASE_BOND_ATTRIBUTES = {
}
}
# version of Fuel when security group switch was added
FUEL_SECURITY_GROUP_VERSION = '9.0'
FUEL_SECURITY_GROUPS_VERSION = '9.0'
def update_vmware_attributes_metadata(upgrade):
@ -345,12 +345,12 @@ def upgrade_release_attributes_metadata(connection):
'WHERE id = :release_id')
for release_id, attrs, release_version in connection.execute(select_query):
if not migration.is_security_group_available(
release_version, FUEL_SECURITY_GROUP_VERSION):
if not migration.is_security_groups_available(
release_version, FUEL_SECURITY_GROUPS_VERSION):
continue
attrs = jsonutils.loads(attrs)
common = attrs.setdefault('editable', {}).setdefault('common', {})
common.setdefault('security_group', SECURITY_GROUP)
common.setdefault('security_groups', SECURITY_GROUPS)
connection.execute(
update_query,
release_id=release_id,
@ -370,12 +370,12 @@ def upgrade_cluster_attributes(connection):
for cluster_id, editable, release_version in connection.execute(
select_query
):
if not migration.is_security_group_available(
release_version, FUEL_SECURITY_GROUP_VERSION):
if not migration.is_security_groups_available(
release_version, FUEL_SECURITY_GROUPS_VERSION):
continue
editable = jsonutils.loads(editable)
editable.setdefault('common', {}).setdefault('security_group',
SECURITY_GROUP)
editable.setdefault('common', {}).setdefault('security_groups',
SECURITY_GROUPS)
connection.execute(
update_query,
cluster_id=cluster_id,
@ -400,7 +400,7 @@ def downgrade_release_attributes_metadata(connection):
for release_id, attrs in connection.execute(select_query):
attrs = jsonutils.loads(attrs)
attrs.setdefault('editable', {}).setdefault('common', {}).pop(
'security_group', None)
'security_groups', None)
connection.execute(
update_query,
release_id=release_id,
@ -418,7 +418,7 @@ def downgrade_cluster_attributes(connection):
for cluster_id, editable in connection.execute(select_query):
editable = jsonutils.loads(editable)
editable.setdefault('common', {}).pop('security_group', None)
editable.setdefault('common', {}).pop('security_groups', None)
connection.execute(
update_query,
cluster_id=cluster_id,

View File

@ -33,7 +33,7 @@ ATTRIBUTES_METADATA = {
'common': {}
}
}
SECURITY_GROUP = {
SECURITY_GROUPS = {
'value': 'iptables_hybrid',
'values': [
{
@ -107,7 +107,7 @@ def prepare():
meta = base.reflect_db_metadata()
attrs_with_sec_group = deepcopy(ATTRIBUTES_METADATA)
attrs_with_sec_group.setdefault('editable', {}).setdefault(
'common', {}).setdefault('security_group', SECURITY_GROUP)
'common', {}).setdefault('security_groups', SECURITY_GROUPS)
plugin = {
'name': 'Test_P',
'version': '3.0.0',
@ -296,7 +296,7 @@ class TestAttributesDowngrade(base.BaseAlembicMigrationTest):
for editable in results:
editable = jsonutils.loads(editable[0])
common = editable.setdefault('common', {})
self.assertEqual(common.get('security_group'), None)
self.assertEqual(common.get('security_groups'), None)
def test_release_attributes_downgrade(self):
releases = self.meta.tables['releases']
@ -305,7 +305,7 @@ class TestAttributesDowngrade(base.BaseAlembicMigrationTest):
for attrs in results:
attrs = jsonutils.loads(attrs[0])
common = attrs.setdefault('editable', {}).setdefault('common', {})
self.assertEqual(common.get('security_group'), None)
self.assertEqual(common.get('security_groups'), None)
class TestTags(base.BaseAlembicMigrationTest):

View File

@ -57,7 +57,7 @@ ATTRIBUTES_METADATA = {
}
}
SECURITY_GROUP = {
SECURITY_GROUPS = {
'value': 'iptables_hybrid',
'values': [
{
@ -523,7 +523,7 @@ class TestAttributesUpdate(base.BaseAlembicMigrationTest):
for attrs in results:
attrs = jsonutils.loads(attrs[0])
common = attrs.setdefault('editable', {}).setdefault('common', {})
self.assertEqual(common.get('security_group'), SECURITY_GROUP)
self.assertEqual(common.get('security_groups'), SECURITY_GROUPS)
def test_release_attributes_no_update(self):
releases = self.meta.tables['releases']
@ -535,7 +535,7 @@ class TestAttributesUpdate(base.BaseAlembicMigrationTest):
for attrs in results:
attrs = jsonutils.loads(attrs[0])
common = attrs.setdefault('editable', {}).setdefault('common', {})
self.assertEqual(common.get('security_group'), None)
self.assertEqual(common.get('security_groups'), None)
def test_cluster_attributes_update(self):
clusters_attributes = self.meta.tables['attributes']
@ -550,7 +550,7 @@ class TestAttributesUpdate(base.BaseAlembicMigrationTest):
for editable in results:
editable = jsonutils.loads(editable[0])
common = editable.setdefault('common', {})
self.assertEqual(common.get('security_group'), SECURITY_GROUP)
self.assertEqual(common.get('security_groups'), SECURITY_GROUPS)
def test_cluster_attributes_no_update(self):
clusters_attributes = self.meta.tables['attributes']
@ -565,7 +565,7 @@ class TestAttributesUpdate(base.BaseAlembicMigrationTest):
for editable in results:
editable = jsonutils.loads(editable[0])
common = editable.setdefault('common', {})
self.assertEqual(common.get('security_group'), None)
self.assertEqual(common.get('security_groups'), None)
def get_release_ids(self, start_version, available=True):
"""Get release ids
@ -585,8 +585,8 @@ class TestAttributesUpdate(base.BaseAlembicMigrationTest):
release_ids = []
for release_id, release_version in results:
if (available ==
migration.is_security_group_available(release_version,
start_version)):
migration.is_security_groups_available(release_version,
start_version)):
release_ids.append(release_id)
return release_ids

View File

@ -570,7 +570,7 @@ def upgrade_cluster_attributes_6_0_to_6_1(connection):
attr_id=attr_id)
def is_security_group_available(release_version, compare_version):
def is_security_groups_available(release_version, compare_version):
env_version = get_environment_version(release_version)
return vers.StrictVersion(env_version) >= vers.StrictVersion(
compare_version)