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"]