diff options
| author | aisch <me+bosch@aitmp.com> | 2016-02-16 21:30:38 -0800 |
|---|---|---|
| committer | aisch <me+bosch@aitmp.com> | 2016-02-16 21:30:38 -0800 |
| commit | d7522b0fb79bffbe10a2548658a48829dd1a5c33 (patch) | |
| tree | 53b9e5f662a0f583f82513c6b4f6e549f7088478 /test | |
| parent | 9f0db5d38b444f5a93da7bed4a19114aff8701e8 (diff) | |
| download | kafka-python-d7522b0fb79bffbe10a2548658a48829dd1a5c33.tar.gz | |
break up some circular references and close client wake pipe on __del__
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_coordinator.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index bf48923..e0906c7 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -19,6 +19,7 @@ from kafka.protocol.commit import ( OffsetCommitResponse, OffsetFetchRequest_v0, OffsetFetchRequest_v1, OffsetFetchResponse) from kafka.protocol.metadata import MetadataResponse +from kafka.util import WeakMethod import kafka.common as Errors @@ -46,7 +47,7 @@ def test_init(conn): # metadata update on init assert cli.cluster._need_update is True - assert coordinator._handle_metadata_update in cli.cluster._listeners + assert WeakMethod(coordinator._handle_metadata_update) in cli.cluster._listeners @pytest.mark.parametrize("api_version", [(0, 8, 0), (0, 8, 1), (0, 8, 2), (0, 9)]) |