diff options
author | Dana Powers <dana.powers@gmail.com> | 2018-03-08 08:17:36 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-03-08 08:17:36 -0800 |
commit | b33a65116ef6936183f09ca56930ccae39378c5f (patch) | |
tree | 8127f25572c061574d733db7d1a1c21934a33a23 /test | |
parent | 4c383daf8a9d7aaa5049a98d7d6da19c85793d2d (diff) | |
download | kafka-python-b33a65116ef6936183f09ca56930ccae39378c5f.tar.gz |
Fix BrokerConnection.connection_delay() to return milliseconds (#1414)
Diffstat (limited to 'test')
-rw-r--r-- | test/test_conn.py | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/test/test_conn.py b/test/test_conn.py index 5698519..f35cebe 100644 --- a/test/test_conn.py +++ b/test/test_conn.py @@ -72,6 +72,15 @@ def test_blacked_out(conn): assert conn.blacked_out() is True +def test_connection_delay(conn): + conn.last_attempt = time.time() + assert round(conn.connection_delay()) == round(conn.config['reconnect_backoff_ms']) + conn.state = ConnectionStates.CONNECTING + assert conn.connection_delay() == 0 + conn.state = ConnectionStates.CONNECTED + assert conn.connection_delay() == float('inf') + + def test_connected(conn): assert conn.connected() is False conn.state = ConnectionStates.CONNECTED |