code: def process(self, *args, **kargs):
      # If value is a list, generate multiple outputs
      value = kargs["value"]
      if isinstance(value, list):
          for v in value:
              self.publish_func(v * self.args["coeff"])
      else:
          self.publish_func(value * self.args["coeff"])
  
imports: from time import sleep
  from petastorm.workers_pool.worker_base import WorkerBase
label_desc: Use image node_id 1 for calling the CoeffMultiplierWorker obj's underlying member method code with example usage: obj.process() without return types