From 54c1dcf117d4b0f5b7329d01d85a56679c647ed4 Mon Sep 17 00:00:00 2001 From: Markus Unterwaditzer Date: Tue, 4 Feb 2020 14:32:39 +0100 Subject: [PATCH 1/2] fix: Try to pin werkzeug --- integration-test-requirements.txt | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/integration-test-requirements.txt b/integration-test-requirements.txt index e088c72df8..1880655351 100644 --- a/integration-test-requirements.txt +++ b/integration-test-requirements.txt @@ -2,9 +2,10 @@ pytest pytest-localserver requests flask +werkzeug==0.15.1 confluent-kafka msgpack pytest-rerunfailures -pytest-xdist -redis +pytest-xdist==1.31.0 +redis==3.4.1 git+https://github.com/untitaker/pytest-sentry#egg=pytest-sentry From 7fdaa0c0cd4bd1bb478533d4a1b78aceebcc061b Mon Sep 17 00:00:00 2001 From: Markus Unterwaditzer Date: Tue, 4 Feb 2020 15:45:46 +0100 Subject: [PATCH 2/2] fix: Close consumer --- tests/integration/fixtures/processing.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tests/integration/fixtures/processing.py b/tests/integration/fixtures/processing.py index 1a9ae4edb7..a2a1780bf5 100644 --- a/tests/integration/fixtures/processing.py +++ b/tests/integration/fixtures/processing.py @@ -125,7 +125,12 @@ def inner(topic: str, options=None): consumer = kafka.Consumer(settings) consumer.subscribe(topics) - request.addfinalizer(consumer.unsubscribe) + + def die(): + consumer.unsubscribe() + consumer.close() + + request.addfinalizer(die) while consumer.poll(timeout=0.1) is not None: pass