code: def process(self, *args, **kargs):
      raise ValueError(
          "worker %d raise test exception - IT SHOULD BE EXCEPTION!"
          % self.worker_id
      )
  
imports: from time import sleep
  from petastorm.workers_pool.worker_base import WorkerBase
label_desc: Use image node_id 1 for calling the ExceptionGeneratingWorker_5 obj's underlying member method code with example usage: obj.process() without return types