From 830a2ff76d0877cabaae9817e77e953983c227a6 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Wed, 23 Mar 2022 17:08:04 +0100 Subject: [PATCH] undo debug intentional crash --- pyinfra/test/unit_tests/consumer_test.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pyinfra/test/unit_tests/consumer_test.py b/pyinfra/test/unit_tests/consumer_test.py index 305d874..436ead8 100644 --- a/pyinfra/test/unit_tests/consumer_test.py +++ b/pyinfra/test/unit_tests/consumer_test.py @@ -81,9 +81,9 @@ class TestConsumer: queue_manager.clear() storage.clear_bucket(bucket_name) - # for data, message in items: - # storage.put_object(**get_object_descriptor(message), data=gzip.compress(data)) - # queue_manager.publish_request(message) + for data, message in items: + storage.put_object(**get_object_descriptor(message), data=gzip.compress(data)) + queue_manager.publish_request(message) requests = consumer.consume(inactivity_timeout=5)