code: def test_bound_size_of_output_queue_size_reader(synthetic_dataset):
      """This test is timing sensitive so it might become flaky"""
      TIME_TO_GET_TO_STATIONARY_STATE = 0.5
  
      with make_reader(
          synthetic_dataset.url,
          reader_pool_type="process",
          workers_count=1,
      ) as reader:
          assert 0 == reader.diagnostics["items_produced"]
          next(reader)
          # Verify that we did not consume all rowgroups (should be 10) and ventilator throttles number of ventilated
          # items
          sleep(TIME_TO_GET_TO_STATIONARY_STATE)
          assert reader.diagnostics["items_consumed"] < 5
          assert reader.diagnostics["items_inprocess"] < 5
  
file_path: petastorm/petastorm/tests/test_reader.py
imports: from time import sleep
  import pyarrow.parquet
  import pytest
  from petastorm import make_reader
  from petastorm.reader import Reader
label_desc: Use image node_id 4 for calling a global function with example usage: test_bound_size_of_output_queue_size_reader(synthetic_dataset) without return types