docstr: Pass a coefficient to the workers and make it multiply the input with this coefficient
docstr_tok: ["Pass","a","coefficient","to","the","workers","and","make","it","multiply","the","input","with","this","coefficient"]
code: def _passing_args_impl(self, pool_class_factory):
      """Pass a coefficient to the workers and make it multiply the input with this coefficient"""
      DELTA = 12
      ITERATIONS = 100
      pool = pool_class_factory()
  
      pool.start(CoeffMultiplierWorker, {"coeff": DELTA})
      for i in range(ITERATIONS):
          pool.ventilate(message="Vent data {}".format(i), value=i)
  
      all_results = [pool.get_results() for _ in range(ITERATIONS)]
      self.assertEqual({DELTA}, set(np.diff(sorted(all_results))))
  
      pool.stop()
      pool.join()
  
imports: import time
  import unittest
  import numpy
  from multiprocessing import Process, Manager
  from psutil import pid_exists
  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 CoeffMultiplierWorker, WorkerIdGeneratingWorker, WorkerMultiIdGeneratingWorker, SleepyWorkerIdGeneratingWorker, ExceptionGeneratingWorker_5, PreprogrammedReturnValueWorker
  from petastorm.workers_pool.thread_pool import ThreadPool
label_desc: Use image node_id 1 for calling the TestWorkersPool obj's underlying member method code with example usage: obj._passing_args_impl(pool_class_factory) without return types