Skip to content

Commit 308b622

Browse files
committed
mock ready in test
1 parent e08308d commit 308b622

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

test/test_fetcher.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@ def test_create_fetch_requests(fetcher, mocker, api_version, fetch_version):
103103
fetcher._client._api_versions = BROKER_API_VERSIONS[api_version]
104104
mocker.patch.object(fetcher._client.cluster, "leader_for_partition", return_value=0)
105105
mocker.patch.object(fetcher._client.cluster, "leader_epoch_for_partition", return_value=0)
106+
mocker.patch.object(fetcher._client, "ready", return_value=True)
106107
by_node = fetcher._create_fetch_requests()
107108
requests_and_offsets = by_node.values()
108109
assert set([r.API_VERSION for (r, _offsets) in requests_and_offsets]) == set([fetch_version])

0 commit comments

Comments
 (0)