code: def process(self, *args, **kargs):
      for value in self._program[self._current_step]:
          self.publish_func(value)
      self._current_step += 1
  
imports: from time import sleep
  from petastorm.workers_pool.worker_base import WorkerBase
label_desc: Use image node_id 2 for calling the PreprogrammedReturnValueWorker obj's underlying member method code with example usage: obj.process() without return types