Fix microversion 2.96

This change fixes missing conditional logic for
microversion 2.96 which adds `pinned_availability_zone`
field to `openstack server list` output.

Conflicts: Resolved the conflict because of missing change
Ia5a4e0047b5123f2fb063cfc9ab1f58b2844308f

Change-Id: I1e398bb3379fa6443b0a44db76baaf6241a945e7
Signed-off-by: Rajesh Tailor <ratailor@redhat.com>
(cherry picked from commit dbddbf9760)
(cherry picked from commit 9b137bfcea)
This commit is contained in:
Rajesh Tailor
2025-06-23 13:17:30 +05:30
parent da91173881
commit 2d5f60b878
2 changed files with 163 additions and 20 deletions

View File

@@ -183,8 +183,12 @@ def _prep_server_detail(compute_client, image_client, server, *, refresh=True):
'updated_at': 'updated', 'updated_at': 'updated',
'user_data': 'OS-EXT-SRV-ATTR:user_data', 'user_data': 'OS-EXT-SRV-ATTR:user_data',
'vm_state': 'OS-EXT-STS:vm_state', 'vm_state': 'OS-EXT-STS:vm_state',
'pinned_availability_zone': 'pinned_availability_zone',
} }
# NOTE(ratailor): microversion 2.96 introduces
# pinned_availability_zone support
if sdk_utils.supports_microversion(compute_client, '2.96'):
column_map['pinned_availability_zone'] = 'pinned_availability_zone'
# Some columns returned by openstacksdk should not be shown because they're # Some columns returned by openstacksdk should not be shown because they're
# either irrelevant or duplicates # either irrelevant or duplicates
ignored_columns = { ignored_columns = {
@@ -235,6 +239,11 @@ def _prep_server_detail(compute_client, image_client, server, *, refresh=True):
info = data info = data
# NOTE(ratailor): microversion 2.96 introduces
# pinned_availability_zone support
if not sdk_utils.supports_microversion(compute_client, '2.96'):
info.pop('pinned_availability_zone', None)
# Convert the image blob to a name # Convert the image blob to a name
image_info = info.get('image', {}) image_info = info.get('image', {})
if image_info and any(image_info.values()): if image_info and any(image_info.values()):
@@ -2870,16 +2879,17 @@ class ListServer(command.Lister):
if parsed_args.long: if parsed_args.long:
columns += ( columns += (
'availability_zone', 'availability_zone',
'pinned_availability_zone',
'hypervisor_hostname', 'hypervisor_hostname',
'metadata', 'metadata',
) )
column_headers += ( column_headers += (
'Availability Zone', 'Availability Zone',
'Pinned Availability Zone',
'Host', 'Host',
'Properties', 'Properties',
) )
if sdk_utils.supports_microversion(compute_client, '2.96'):
columns += ('pinned_availability_zone',)
column_headers += ('Pinned Availability Zone',)
# support for additional columns # support for additional columns
if parsed_args.columns: if parsed_args.columns:
@@ -2913,10 +2923,11 @@ class ListServer(command.Lister):
column_headers += ('Availability Zone',) column_headers += ('Availability Zone',)
if c in ( if c in (
'pinned_availability_zone', 'pinned_availability_zone',
"Pinned Availability Zone", 'Pinned Availability Zone',
): ):
columns += ('Pinned Availability Zone',) if sdk_utils.supports_microversion(compute_client, '2.96'):
column_headers += ('Pinned Availability Zone',) columns += ('pinned_availability_zone',)
column_headers += ('Pinned Availability Zone',)
if c in ('Host', "host"): if c in ('Host', "host"):
columns += ('hypervisor_hostname',) columns += ('hypervisor_hostname',)
column_headers += ('Host',) column_headers += ('Host',)

View File

@@ -1227,7 +1227,6 @@ class TestServerCreate(TestServer):
'locked', 'locked',
'locked_reason', 'locked_reason',
'name', 'name',
'pinned_availability_zone',
'progress', 'progress',
'project_id', 'project_id',
'properties', 'properties',
@@ -1276,7 +1275,6 @@ class TestServerCreate(TestServer):
None, # locked None, # locked
None, # locked_reason None, # locked_reason
self.server.name, self.server.name,
None, # pinned_availability_zone
None, # progress None, # progress
None, # project_id None, # project_id
format_columns.DictColumn({}), # properties format_columns.DictColumn({}), # properties
@@ -4600,7 +4598,6 @@ class _TestServerList(TestServer):
'Flavor Name', 'Flavor Name',
'Flavor ID', 'Flavor ID',
'Availability Zone', 'Availability Zone',
'Pinned Availability Zone',
'Host', 'Host',
'Properties', 'Properties',
) )
@@ -4739,7 +4736,6 @@ class TestServerList(_TestServerList):
self.flavor.name, self.flavor.name,
s.flavor['id'], s.flavor['id'],
getattr(s, 'availability_zone'), getattr(s, 'availability_zone'),
getattr(s, 'pinned_availability_zone', ''),
server.HostColumn(getattr(s, 'hypervisor_hostname')), server.HostColumn(getattr(s, 'hypervisor_hostname')),
format_columns.DictColumn(s.metadata), format_columns.DictColumn(s.metadata),
) )
@@ -4785,8 +4781,6 @@ class TestServerList(_TestServerList):
'-c', '-c',
'Availability Zone', 'Availability Zone',
'-c', '-c',
'Pinned Availability Zone',
'-c',
'Host', 'Host',
'-c', '-c',
'Properties', 'Properties',
@@ -4809,7 +4803,6 @@ class TestServerList(_TestServerList):
self.assertIn('Image ID', columns) self.assertIn('Image ID', columns)
self.assertIn('Flavor ID', columns) self.assertIn('Flavor ID', columns)
self.assertIn('Availability Zone', columns) self.assertIn('Availability Zone', columns)
self.assertIn('Pinned Availability Zone', columns)
self.assertIn('Host', columns) self.assertIn('Host', columns)
self.assertIn('Properties', columns) self.assertIn('Properties', columns)
self.assertCountEqual(columns, set(columns)) self.assertCountEqual(columns, set(columns))
@@ -5222,7 +5215,6 @@ class TestServerList(_TestServerList):
self.flavor.name, self.flavor.name,
s.flavor['id'], s.flavor['id'],
getattr(s, 'availability_zone'), getattr(s, 'availability_zone'),
getattr(s, 'pinned_availability_zone', ''),
server.HostColumn(getattr(s, 'hypervisor_hostname')), server.HostColumn(getattr(s, 'hypervisor_hostname')),
format_columns.DictColumn(s.metadata), format_columns.DictColumn(s.metadata),
) )
@@ -5277,7 +5269,6 @@ class TestServerList(_TestServerList):
self.flavor.name, self.flavor.name,
s.flavor['id'], s.flavor['id'],
getattr(s, 'availability_zone'), getattr(s, 'availability_zone'),
getattr(s, 'pinned_availability_zone', ''),
server.HostColumn(getattr(s, 'hypervisor_hostname')), server.HostColumn(getattr(s, 'hypervisor_hostname')),
format_columns.DictColumn(s.metadata), format_columns.DictColumn(s.metadata),
s.host_status, s.host_status,
@@ -5314,7 +5305,6 @@ class TestServerListV273(_TestServerList):
'Image ID', 'Image ID',
'Flavor', 'Flavor',
'Availability Zone', 'Availability Zone',
'Pinned Availability Zone',
'Host', 'Host',
'Properties', 'Properties',
) )
@@ -5513,6 +5503,152 @@ class TestServerListV273(_TestServerList):
self.assertEqual(expected_row, partial_server) self.assertEqual(expected_row, partial_server)
class TestServerListV296(_TestServerList):
columns = (
'ID',
'Name',
'Status',
'Networks',
'Image',
'Flavor',
)
columns_long = (
'ID',
'Name',
'Status',
'Task State',
'Power State',
'Networks',
'Image Name',
'Image ID',
'Flavor',
'Availability Zone',
'Host',
'Properties',
'Pinned Availability Zone',
)
def setUp(self):
super().setUp()
self.set_compute_api_version('2.96')
Image = collections.namedtuple('Image', 'id name')
self.image_client.images.return_value = [
Image(id=s.image['id'], name=self.image.name)
# Image will be an empty string if boot-from-volume
for s in self.servers
if s.image
]
Flavor = collections.namedtuple('Flavor', 'id name')
self.compute_sdk_client.flavors.return_value = [
Flavor(id=s.flavor['id'], name=self.flavor.name)
for s in self.servers
]
self.data = tuple(
(
s.id,
s.name,
s.status,
server.AddressesColumn(s.addresses),
# Image will be an empty string if boot-from-volume
self.image.name if s.image else server.IMAGE_STRING_FOR_BFV,
self.flavor.name,
)
for s in self.servers
)
def test_server_list_long_option(self):
self.data = tuple(
(
s.id,
s.name,
s.status,
getattr(s, 'task_state'),
server.PowerStateColumn(getattr(s, 'power_state')),
server.AddressesColumn(s.addresses),
# Image will be an empty string if boot-from-volume
self.image.name if s.image else server.IMAGE_STRING_FOR_BFV,
s.image['id'] if s.image else server.IMAGE_STRING_FOR_BFV,
self.flavor.name,
getattr(s, 'availability_zone'),
server.HostColumn(getattr(s, 'hypervisor_hostname')),
format_columns.DictColumn(s.metadata),
getattr(s, 'pinned_availability_zone', ''),
)
for s in self.servers
)
arglist = [
'--long',
]
verifylist = [
('all_projects', False),
('long', True),
]
parsed_args = self.check_parser(self.cmd, arglist, verifylist)
columns, data = self.cmd.take_action(parsed_args)
self.compute_sdk_client.servers.assert_called_with(**self.kwargs)
image_ids = {s.image['id'] for s in self.servers if s.image}
self.image_client.images.assert_called_once_with(
id=f'in:{",".join(image_ids)}',
)
self.compute_sdk_client.flavors.assert_called_once_with(is_public=None)
self.assertEqual(self.columns_long, columns)
self.assertEqual(self.data, tuple(data))
def test_server_list_column_option(self):
arglist = [
'-c',
'Project ID',
'-c',
'User ID',
'-c',
'Created At',
'-c',
'Security Groups',
'-c',
'Task State',
'-c',
'Power State',
'-c',
'Image ID',
'-c',
'Flavor ID',
'-c',
'Availability Zone',
'-c',
'Host',
'-c',
'Properties',
'-c',
'Pinned Availability Zone',
'--long',
]
verifylist = [
('long', True),
]
parsed_args = self.check_parser(self.cmd, arglist, verifylist)
columns, data = self.cmd.take_action(parsed_args)
self.compute_sdk_client.servers.assert_called_with(**self.kwargs)
self.assertIn('Project ID', columns)
self.assertIn('User ID', columns)
self.assertIn('Created At', columns)
self.assertIn('Security Groups', columns)
self.assertIn('Task State', columns)
self.assertIn('Power State', columns)
self.assertIn('Image ID', columns)
self.assertIn('Flavor ID', columns)
self.assertIn('Availability Zone', columns)
self.assertIn('Pinned Availability Zone', columns)
self.assertIn('Host', columns)
self.assertIn('Properties', columns)
self.assertCountEqual(columns, set(columns))
class TestServerAction(compute_fakes.TestComputev2): class TestServerAction(compute_fakes.TestComputev2):
def run_method_with_sdk_servers(self, method_name, server_count): def run_method_with_sdk_servers(self, method_name, server_count):
servers = compute_fakes.create_sdk_servers(count=server_count) servers = compute_fakes.create_sdk_servers(count=server_count)
@@ -8443,7 +8579,6 @@ class TestServerShow(TestServer):
'locked', 'locked',
'locked_reason', 'locked_reason',
'name', 'name',
'pinned_availability_zone',
'progress', 'progress',
'project_id', 'project_id',
'properties', 'properties',
@@ -8493,7 +8628,6 @@ class TestServerShow(TestServer):
None, # locked None, # locked
None, # locked_reason None, # locked_reason
self.server.name, self.server.name,
None, # pinned_availability_zone
None, # progress None, # progress
'tenant-id-xxx', # project_id 'tenant-id-xxx', # project_id
format_columns.DictColumn({}), # properties format_columns.DictColumn({}), # properties
@@ -9444,7 +9578,6 @@ class TestServerGeneral(TestServer):
'locked': None, 'locked': None,
'locked_reason': None, 'locked_reason': None,
'name': _server.name, 'name': _server.name,
'pinned_availability_zone': None,
'progress': None, 'progress': None,
'project_id': 'tenant-id-xxx', 'project_id': 'tenant-id-xxx',
'properties': format_columns.DictColumn({}), 'properties': format_columns.DictColumn({}),
@@ -9531,7 +9664,6 @@ class TestServerGeneral(TestServer):
'locked': None, 'locked': None,
'locked_reason': None, 'locked_reason': None,
'name': _server.name, 'name': _server.name,
'pinned_availability_zone': None,
'progress': None, 'progress': None,
'project_id': 'tenant-id-xxx', 'project_id': 'tenant-id-xxx',
'properties': format_columns.DictColumn({}), 'properties': format_columns.DictColumn({}),