diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-30 19:29:30 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-03-30 19:29:30 -0700 |
| commit | b1effa24aca3a6bcf2268354caae12ee82d6b36d (patch) | |
| tree | a2e5c80a0c85468ba2aff9b1fcc6e974a96fed53 /test/test_client_async.py | |
| parent | de6e9d3cc31db2d513e8d8f9dde4d77d400325ce (diff) | |
| download | kafka-python-b1effa24aca3a6bcf2268354caae12ee82d6b36d.tar.gz | |
Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)
Diffstat (limited to 'test/test_client_async.py')
| -rw-r--r-- | test/test_client_async.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_client_async.py b/test/test_client_async.py index 3588423..246e36c 100644 --- a/test/test_client_async.py +++ b/test/test_client_async.py @@ -332,7 +332,7 @@ def test_maybe_refresh_metadata_update(mocker, client): client._poll.assert_called_with(9999.999) # request_timeout_ms assert client._metadata_refresh_in_progress request = MetadataRequest[0]([]) - send.assert_called_once_with('foobar', request) + send.assert_called_once_with('foobar', request, wakeup=False) def test_maybe_refresh_metadata_cant_send(mocker, client): @@ -348,7 +348,7 @@ def test_maybe_refresh_metadata_cant_send(mocker, client): # first poll attempts connection client.poll(timeout_ms=12345678) client._poll.assert_called_with(2.222) # reconnect backoff - client.maybe_connect.assert_called_once_with('foobar') + client.maybe_connect.assert_called_once_with('foobar', wakeup=False) # poll while connecting should not attempt a new connection client._connecting.add('foobar') |