diff --git a/pyinfra/test/unit_tests/consumer_test.py b/pyinfra/test/unit_tests/consumer_test.py index 436ead8..305d874 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)