openstack
/
ovn-octavia-provider
Code Issues Proposed changes

Merge "Fix request to OVN NB DB API"

This commit is contained in:
Zuul 2022-05-30 15:39:53 +00:00 committed by Gerrit Code Review
parent 201e8be046 61a56dc377
commit a6dbd27b76
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ovn_octavia_provider/helper.py
View File

@ -2430,8 +2430,8 @@ class OvnProviderHelper():
member_ip = f'[{member_ip}]'
mappings[member_ip] = member_src
lbs = self.ovn_nbdb_api.db_find_rows(
'Load_Balancer', (('ip_port_mappings', '=', mappings),
('protocol', '=', row.protocol))).execute()
'Load_Balancer', ('ip_port_mappings', '=', mappings),
('protocol', '=', row.protocol[0])).execute()
return lbs[0] if lbs else None
def hm_update_event_handler(self, row):

6
ovn_octavia_provider/tests/unit/test_helper.py
View File

@ -3614,9 +3614,9 @@ class TestOvnProviderHelper(ovn_base.TestOvnOctaviaBase):
self.mock_add_request.assert_called_once_with(expected)
self.helper.ovn_nbdb_api.db_find_rows.assert_called_once_with(
'Load_Balancer',
(('ip_port_mappings', '=',
{self.member_address: 'a-logical-port:' + src_ip}),
('protocol', '=', self.ovn_hm_lb.protocol)))
('ip_port_mappings', '=',
{self.member_address: 'a-logical-port:' + src_ip}),
('protocol', '=', self.ovn_hm_lb.protocol[0]))
def test_hm_update_event_lb_not_found(self):
self.helper.ovn_nbdb_api.db_find_rows.return_value.\