diff --git a/pyinfra/test/unit_tests/consumer_test.py b/pyinfra/test/unit_tests/consumer_test.py
index 1786d8b..7b7a570 100644
--- a/pyinfra/test/unit_tests/consumer_test.py
+++ b/pyinfra/test/unit_tests/consumer_test.py
@@ -46,38 +46,6 @@ class TestConsumer:
 
         assert queue_manager.output_queue.to_list() == ["00", "11", "22"]
 
-    # @pytest.mark.parametrize("client_name", ["mock", "s3", "azure"], scope="session")
-    # @pytest.mark.parametrize("response_strategy_name", ["forwarding", "storage"], scope="session")
-    # def test_consuming_nonempty_input_queue_with_visitor_puts_messages_on_output_queue_in_fifo_order(
-    #         self, consumer, queue_manager, visitor, storage, bucket_name
-    # ):
-    #
-    #     def produce_items():
-    #         for i in range(3):
-    #             body = {
-    #                 "dossierId": "folder",
-    #                 "fileId": f"file{i}",
-    #                 "targetFileExtension": "in.gz",
-    #                 "responseFileExtension": "out.gz"
-    #             }
-    #             yield f"{i}".encode(), body
-    #
-    #     visitor.response_strategy = ForwardingStrategy()
-    #
-    #     queue_manager.clear()
-    #     storage.clear_bucket(bucket_name)
-    #
-    #     for data, message in produce_items():
-    #         storage.put_object(**get_object_descriptor(message), data=gzip.compress(data))
-    #         queue_manager.publish_request(message)
-    #
-    #     requests = consumer.consume()
-    #
-    #     for _, r in zip(produce_items(), requests):
-    #         queue_manager.publish_response(r, visitor)
-    #
-    #     assert list(map(itemgetter("data"), queue_manager.output_queue.to_list())) == ["00", "11", "22"]
-
     @pytest.mark.parametrize("client_name", ["mock", "s3", "azure"], scope="session")
     @pytest.mark.parametrize("response_strategy_name", ["forwarding", "storage"], scope="session")
     def test_consuming_nonempty_input_queue_with_visitor_puts_messages_on_output_queue_in_fifo_order(