class_docstr: node_info:
      name
      func_type: operator/lambda
      node_type: map/filter/flat_map/window/time_window/window_all
      input_schema: (name, name)
      output_schema: (name, name, name)
      # operator meta info:
      op_info: {
          hub_id: '',
          name: '',
          args: [],
          kwargs: {},
          tag: ''
      },
      config: {}
code: def initialize(self) -> bool:
      # TODO
      # Create multiple-operators to support parallelism.
      # Read the parallelism info by config.
      op_type = self._node_repr.op_info.type
      if op_type in [OPType.HUB, OPType.BUILTIN]:
          try:
              hub_id = self._node_repr.op_info.operator
              with set_runtime_config(self._node_repr.config):
                  self._time_profiler.record(self.uid, Event.init_in)
                  self._op = self._op_pool.acquire_op(
                      self.uid,
                      hub_id,
                      self._node_repr.op_info.init_args,
                      self._node_repr.op_info.init_kws,
                      self._node_repr.op_info.tag,
                      self._node_repr.op_info.latest,
                  )
                  self._time_profiler.record(self.uid, Event.init_out)
                  return True
          except Exception as e:  # pylint: disable=broad-except
              st_err = "{}, {}".format(str(e), traceback.format_exc())
              err = "Create {} operator {}:{} with args {} and kws {} failed, err: {}".format(
                  self.name,
                  hub_id,
                  self._node_repr.op_info.tag,
                  str(self._node_repr.op_info.init_args),
                  str(self._node_repr.op_info.init_kws),
                  str(st_err),
              )
              self._set_failed(err)
          return False
      elif op_type in [OPType.LAMBDA, OPType.CALLABLE]:
          self._op = self._node_repr.op_info.operator
          return True
      else:
          err = "Unkown callable type {}".format(op_type)
          self._set_failed(err)
          return False
  
imports: from typing import List
  from enum import Enum, auto
  from abc import ABC
  import traceback
  from towhee.runtime.data_queue import DataQueue
  from towhee.runtime.runtime_conf import set_runtime_config
  from towhee.runtime.constants import OPType
  from towhee.runtime.time_profiler import Event, TimeProfiler
  from towhee.utils.log import engine_log
label_desc: Use image node_id 2 for calling the Node obj's underlying member method code with example usage: obj.initialize() and returns: False, True, False, True