def test_disable_zmq_copy_buffers_in_reader(synthetic_dataset):
    """Assert that the underlying ProcessPool has zmq_copy_buffers disabled"""

    with make_reader(synthetic_dataset.url, reader_pool_type='process',
                     workers_count=1, zmq_copy_buffers=False) as reader:
        assert not reader.diagnostics['zmq_copy_buffers']
Assert that the underlying ProcessPool has zmq_copy_buffers disabled
petastorm/tests/test_reader.py