summaryrefslogtreecommitdiff
path: root/test/test_producer.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2018-01-11 17:41:36 -0800
committerDana Powers <dana.powers@gmail.com>2018-01-11 17:41:36 -0800
commit9a19258b1dc08801a09994461bf623687156ee33 (patch)
tree19acb8f5a29946d63a81cc5ed36363e7c39efdb5 /test/test_producer.py
parenta8bf19f88e89bef571b7c1f952010bf405054987 (diff)
downloadkafka-python-test_cleanups.tar.gz
Minor test cleanupstest_cleanups
Diffstat (limited to 'test/test_producer.py')
-rw-r--r--test/test_producer.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/test/test_producer.py b/test/test_producer.py
index 20dffc2..f7a5b68 100644
--- a/test/test_producer.py
+++ b/test/test_producer.py
@@ -72,6 +72,7 @@ def test_end_to_end(kafka_broker, compression):
@pytest.mark.skipif(platform.python_implementation() != 'CPython',
reason='Test relies on CPython-specific gc policies')
def test_kafka_producer_gc_cleanup():
+ gc.collect()
threads = threading.active_count()
producer = KafkaProducer(api_version='0.9') # set api_version explicitly to avoid auto-detection
assert threading.active_count() == threads + 1