Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

processing log added to test

Browse Source
This commit is contained in:
Matthias Bisping 2022-03-24 09:51:52 +01:00
parent 21e519a6cd
commit 17e11adf78
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pyinfra/test/unit_tests/consumer_test.py
View File

@ -9,6 +9,9 @@ from pyinfra.exceptions import ProcessingFailure
from pyinfra.queue.consumer import Consumer from pyinfra.queue.consumer import Consumer
from pyinfra.visitor import get_object_descriptor, ForwardingStrategy from pyinfra.visitor import get_object_descriptor, ForwardingStrategy
logger = logging.getLogger(__name__)
logger.setLevel(logging.DEBUG)
@pytest.fixture(scope="session") @pytest.fixture(scope="session")
def consumer(queue_manager, callback): def consumer(queue_manager, callback):
@ -87,8 +90,9 @@ class TestConsumer:
requests = consumer.consume(inactivity_timeout=5) requests = consumer.consume(inactivity_timeout=5)
for _, r in zip(items, requests): for itm, req in zip(items, requests):
queue_manager.publish_response(r, visitor) 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"] assert list(map(itemgetter("data"), queue_manager.output_queue.to_list())) == ["00", "11", "22"]