openstack/kuryr-kubernetes
Code Issues Proposed changes

Merge "Fix Python 3 compatiblity in K8sClient.watch()"

Browse Source
This commit is contained in:
Zuul 2018-09-13 11:29:27 +00:00 committed by Gerrit Code Review
commit c265560fa8
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kuryr_kubernetes/k8s_client.py
View File

@ -197,7 +197,7 @@ class K8sClient(object):
headers=header)) as response: headers=header)) as response:
if not response.ok: if not response.ok:
raise exc.K8sClientException(response.text) raise exc.K8sClientException(response.text)
for line in response.iter_lines(delimiter='\n'): for line in response.iter_lines():
line = line.strip() line = line.decode('utf-8').strip()
if line: if line:
yield jsonutils.loads(line) yield jsonutils.loads(line)

2
kuryr_kubernetes/tests/unit/test_k8s_client.py
View File

@ -311,7 +311,7 @@ class TestK8sClient(test_base.TestCase):
def test_watch(self, m_get): def test_watch(self, m_get):
path = '/test' path = '/test'
data = [{'obj': 'obj%s' % i} for i in range(3)] data = [{'obj': 'obj%s' % i} for i in range(3)]
lines = [jsonutils.dumps(i) for i in data] lines = [jsonutils.dump_as_bytes(i) for i in data]
m_resp = mock.MagicMock() m_resp = mock.MagicMock()
m_resp.ok = True m_resp.ok = True