From 17e11adf7822916dd3ece201529796e4dfd89032 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Thu, 24 Mar 2022 09:51:52 +0100 Subject: [PATCH] processing log added to test --- pyinfra/test/unit_tests/consumer_test.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pyinfra/test/unit_tests/consumer_test.py b/pyinfra/test/unit_tests/consumer_test.py index 436ead8..5874846 100644 --- a/pyinfra/test/unit_tests/consumer_test.py +++ b/pyinfra/test/unit_tests/consumer_test.py @@ -9,6 +9,9 @@ from pyinfra.exceptions import ProcessingFailure from pyinfra.queue.consumer import Consumer from pyinfra.visitor import get_object_descriptor, ForwardingStrategy +logger = logging.getLogger(__name__) +logger.setLevel(logging.DEBUG) + @pytest.fixture(scope="session") def consumer(queue_manager, callback): @@ -87,8 +90,9 @@ class TestConsumer: requests = consumer.consume(inactivity_timeout=5) - for _, r in zip(items, requests): - queue_manager.publish_response(r, visitor) + for itm, req in zip(items, requests): + logger.debug(f"Processing item {itm}") + queue_manager.publish_response(req, visitor) assert list(map(itemgetter("data"), queue_manager.output_queue.to_list())) == ["00", "11", "22"]