diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-11 16:09:04 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-11 16:09:04 -0800 |
| commit | dcad3fea16028ae00f64baa981553b62666b15fb (patch) | |
| tree | 359efbf989590f2bbe7637a31fd53b895774539b | |
| parent | 829b0379eb6f4df2e20fceb6673ad60e21b348f3 (diff) | |
| download | kafka-python-dcad3fea16028ae00f64baa981553b62666b15fb.tar.gz | |
Add mocking to test_coordinator::test_close to fix random test failure (via travis logs)
| -rw-r--r-- | test/test_coordinator.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index f7c5772..80d2de2 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -269,6 +269,7 @@ def test_fetch_committed_offsets(mocker, coordinator): def test_close(mocker, coordinator): mocker.patch.object(coordinator, '_maybe_auto_commit_offsets_sync') mocker.patch.object(coordinator, '_handle_leave_group_response') + mocker.patch.object(coordinator, 'coordinator_unknown', return_value=False) coordinator.coordinator_id = 0 coordinator.generation = 1 cli = coordinator._client |