diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-03-13 22:01:13 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-03-13 22:01:13 +0000 |
| commit | 30063dd5a53170b9c95e02c882abce10419e7ca2 (patch) | |
| tree | 43155ec4df6caf23ec1aeded2a1164fcd70e363f | |
| parent | 6c96898019174d4c7b4b081a2c9016a51bdfa4f1 (diff) | |
| parent | edf57ca3f4e822e45300f50471fbb90f14f1ab94 (diff) | |
| download | nova-30063dd5a53170b9c95e02c882abce10419e7ca2.tar.gz nova-30063dd5a53170b9c95e02c882abce10419e7ca2.tar.xz nova-30063dd5a53170b9c95e02c882abce10419e7ca2.zip | |
Merge "Don't load system_metadata when it isn't joined."
| -rw-r--r-- | nova/db/sqlalchemy/api.py | 2 | ||||
| -rw-r--r-- | nova/db/sqlalchemy/models.py | 2 | ||||
| -rw-r--r-- | nova/tests/test_db_api.py | 14 |
3 files changed, 15 insertions, 3 deletions
diff --git a/nova/db/sqlalchemy/api.py b/nova/db/sqlalchemy/api.py index 8d2d68b09..ba8595186 100644 --- a/nova/db/sqlalchemy/api.py +++ b/nova/db/sqlalchemy/api.py @@ -3326,7 +3326,7 @@ def migration_get_in_progress_by_host_and_node(context, host, node, and_(models.Migration.dest_compute == host, models.Migration.dest_node == node))).\ filter(~models.Migration.status.in_(['confirmed', 'reverted'])).\ - options(joinedload('instance')).\ + options(joinedload_all('instance.system_metadata')).\ all() diff --git a/nova/db/sqlalchemy/models.py b/nova/db/sqlalchemy/models.py index 3f45c614b..ce5f84578 100644 --- a/nova/db/sqlalchemy/models.py +++ b/nova/db/sqlalchemy/models.py @@ -154,7 +154,7 @@ class Instance(BASE, NovaBase): return base_name def _extra_keys(self): - return ['name', 'system_metadata'] + return ['name'] user_id = Column(String(255)) project_id = Column(String(255)) diff --git a/nova/tests/test_db_api.py b/nova/tests/test_db_api.py index 1dd62b561..bb6b3817b 100644 --- a/nova/tests/test_db_api.py +++ b/nova/tests/test_db_api.py @@ -1554,10 +1554,14 @@ class MigrationTestCase(test.TestCase): self._create(source_compute='host3', dest_compute='host4') def _create(self, status='migrating', source_compute='host1', - source_node='a', dest_compute='host2', dest_node='b'): + source_node='a', dest_compute='host2', dest_node='b', + system_metadata=None): values = {'host': source_compute} instance = db.instance_create(self.ctxt, values) + if system_metadata: + db.instance_system_metadata_update(self.ctxt, instance['uuid'], + system_metadata, False) values = {'status': status, 'source_compute': source_compute, 'source_node': source_node, 'dest_compute': dest_compute, @@ -1569,6 +1573,14 @@ class MigrationTestCase(test.TestCase): self.assertNotEqual('confirmed', migration['status']) self.assertNotEqual('reverted', migration['status']) + def test_migration_get_in_progress_joins(self): + self._create(source_compute='foo', system_metadata={'foo': 'bar'}) + migrations = db.migration_get_in_progress_by_host_and_node(self.ctxt, + 'foo', 'a') + system_metadata = migrations[0]['instance']['system_metadata'][0] + self.assertEqual(system_metadata['key'], 'foo') + self.assertEqual(system_metadata['value'], 'bar') + def test_in_progress_host1_nodea(self): migrations = db.migration_get_in_progress_by_host_and_node(self.ctxt, 'host1', 'a') |