docstr: Can not reset ventilator in the middle of ventilation
docstr_tok: ["Can","not","reset","ventilator","in","the","middle","of","ventilation"]
code: def test_reset_in_the_middle_of_ventilation(self):
      """Can not reset ventilator in the middle of ventilation"""
      for pool in [DummyPool(), ThreadPool(10)]:
          ventilator = ConcurrentVentilator(
              ventilate_fn=pool.ventilate,
              items_to_ventilate=[{"item": i} for i in range(100)],
              iterations=None,
          )
          pool.start(IdentityWorker, ventilator=ventilator)
  
          # Resetting is supported only when the ventilator has finished
          with self.assertRaises(NotImplementedError):
              ventilator.reset()
  
          pool.stop()
          pool.join()
  
imports: import time
  import unittest
  from petastorm.workers_pool import EmptyResultError
  from petastorm.workers_pool.dummy_pool import DummyPool
  from petastorm.workers_pool.process_pool import ProcessPool
  from petastorm.workers_pool.tests.stub_workers import IdentityWorker
  from petastorm.workers_pool.thread_pool import ThreadPool
  from petastorm.workers_pool.ventilator import ConcurrentVentilator
label_desc: Use image node_id 6 for calling the TestWorkersPool obj's underlying member method code with example usage: obj.test_reset_in_the_middle_of_ventilation() without return types