def test_deciqueue_output(queued_client, large_queue):
    queued_client.flush()
    for description in large_queue:
        assert description in queued_client.transport.string.getvalue()
dataset/ETHPy150Open borntyping/python-riemann-client/tests/test_riemann_queued_client.py/test_deciqueue_output/original