diff options
author | Dana Powers <dana.powers@gmail.com> | 2017-10-24 16:05:50 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-10-24 16:05:50 -0700 |
commit | d2001e4b69c2b03202a44899b687b05e735261a8 (patch) | |
tree | 5662b887c203a843d4b0484aed32fb2bb59423c1 /test | |
parent | 8b05ee8da50b4c7b832676f4e38f9d92a86639cc (diff) | |
download | kafka-python-d2001e4b69c2b03202a44899b687b05e735261a8.tar.gz |
Handle lookup_coordinator send failures (#1279)
Diffstat (limited to 'test')
-rw-r--r-- | test/test_coordinator.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index aea2662..0e96110 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -590,3 +590,11 @@ def test_heartbeat(patched_coord): patched_coord.heartbeat_task() assert patched_coord._client.schedule.call_count == 1 assert patched_coord.heartbeat_task._handle_heartbeat_failure.call_count == 1 + + +def test_lookup_coordinator_failure(mocker, coordinator): + + mocker.patch.object(coordinator, '_send_group_coordinator_request', + return_value=Future().failure(Exception('foobar'))) + future = coordinator.lookup_coordinator() + assert future.failed() |