code: def run(self):
      while True:
          # Get work from the remote queue.
          work_item = ray.get(self.work_queue.get_work_item.remote())
  
          if work_item is None:
              break
  
          # Do work.
          self.process(work_item)
  
file_path: ray/doc/source/ray-core/doc_code/pattern_pipelining.py
imports: import ray
label_desc: Use image node_id 3 for calling the WorkerWithoutPipelining obj's underlying member method code with example usage: obj.run() without return types