diff options
| author | Zack Dever <zdever@pandora.com> | 2016-04-25 14:48:50 -0700 |
|---|---|---|
| committer | Zack Dever <zdever@pandora.com> | 2016-04-25 14:48:50 -0700 |
| commit | 87e71b4e781a1d1a92d4e538f44036ae9ff9c593 (patch) | |
| tree | 69554475e0b102ac63a5bdb0375c7b48df70a7ee | |
| parent | 0300edb353e8581e47cb06a3294f9456d4e7ad2d (diff) | |
| download | kafka-python-87e71b4e781a1d1a92d4e538f44036ae9ff9c593.tar.gz | |
enable errors on callbacks in testing. fix broken test.
| -rw-r--r-- | test/__init__.py | 3 | ||||
| -rw-r--r-- | test/test_coordinator.py | 2 |
2 files changed, 4 insertions, 1 deletions
diff --git a/test/__init__.py b/test/__init__.py index f91d0fa..0eb2edc 100644 --- a/test/__init__.py +++ b/test/__init__.py @@ -15,3 +15,6 @@ except ImportError: pass logging.getLogger(__name__).addHandler(NullHandler()) + +from kafka.future import Future +Future.error_on_callbacks = True # always fail during testing diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 4b90f30..15b915d 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -548,7 +548,7 @@ def test_send_offset_fetch_request_success(patched_coord, partitions): patched_coord._client.send.return_value = _f future = patched_coord._send_offset_fetch_request(partitions) (node, request), _ = patched_coord._client.send.call_args - response = OffsetFetchResponse[0]([('foobar', [(0, 0), (1, 0)])]) + response = OffsetFetchResponse[0]([('foobar', [(0, 123, b'', 0), (1, 234, b'', 0)])]) _f.success(response) patched_coord._handle_offset_fetch_response.assert_called_with( future, response) |