diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-04-25 16:27:37 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-04-25 16:27:37 -0700 |
| commit | 22dd002800839fd0788648e8308104bb012d96b7 (patch) | |
| tree | fb99058c606a14d46b911ded6ea640364d562b3f /test | |
| parent | c7564d239795f9d20f5a027f32130ee1ae84ab3e (diff) | |
| parent | 87e71b4e781a1d1a92d4e538f44036ae9ff9c593 (diff) | |
| download | kafka-python-22dd002800839fd0788648e8308104bb012d96b7.tar.gz | |
Merge pull request #670 from zackdever/predictable-future
Consistent error handling in future call/errbacks + better test failures
Diffstat (limited to '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) |