code: def __init__(
      self,
      fn,
      emitter,
      batch_size=1,
      queue_size=50,
      encode=identity,
      decode=identity,
  ):
      self.fn = fn
      self.emitter = emitter
      self.batch_size = batch_size
      self.queue_size = queue_size
      self.encode = encode
      self.decode = decode
  
file_path: gluonts/src/gluonts/nursery/glide/parallel.py
imports: import multiprocessing
  from functools import partial
  from toolz.itertoolz import partition_all
  from toolz.functoolz import identity
label_desc: Use image node_id 1 to create a new ParApply object  with example: obj = ParApply(fn, emitter, batch_size, queue_size, encode, decode)