From bbc73a6bbcbdd847cfa2d6ae31e4bb40fa908508 Mon Sep 17 00:00:00 2001 From: bninja Date: Tue, 19 Aug 2014 22:54:51 -0700 Subject: [PATCH] so --- test.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/test.py b/test.py index 4739455..986e480 100644 --- a/test.py +++ b/test.py @@ -29,7 +29,7 @@ consumed = { @pytest.fixture(scope='session', autouse=True) -def consume(request, params): +def consume(params): def _callback(ch, method, properties, body): msg = Message.from_json(body) @@ -43,9 +43,9 @@ def consume(request, params): channel.queue_declare(queue='pika_pool_test') channel.basic_consume(_callback, queue='pika_pool_test', no_ack=True) - threading.Thread(target=_forever).start() - - request.addfinalizer(lambda: channel.stop_consuming()) + thd = threading.Thread(target=_forever) + thd.daemon = True + thd.start() @pytest.fixture