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

removed obsolete code

Browse Source
This commit is contained in:
Matthias Bisping 2022-03-14 14:47:47 +01:00
parent f21cbc141e
commit 32740a914f
1 changed files with 0 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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(