code: def __init__(self):
      self._pipe = BufferedPipe()
  
imports: import types
  from studio.util import logs
  from PIL import Image
  from threading import Thread
  import numpy
  import itertools
  import six
label_desc: Use image node_id 1 to create a new ModelPipe object  with example: obj = ModelPipe()