code: def add(
      self,
      func,
      num_workers=None,
      batch_size=None,
      filterf=None,
      batcher=None,
      timeout=None,
  ):
      if keras and (
          isinstance(func, keras.models.Sequential)
          or isinstance(func, keras.models.Model)
      ):
          model = func
          _prime_keras_model(func)
          func = model.predict
  
      self._pipe = self._pipe.add(
          func,
          num_workers,
          batch_size=batch_size,
          filterf=filterf,
          batcher=batcher,
          timeout=timeout,
      )
      return self
  
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 2 for calling the ModelPipe obj's underlying member method code with example usage: obj.add(func, num_workers, batch_size, filterf, batcher, timeout) and returns: self