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 __init__(
      self,
      node_repr: "NodeRepr",
      op_pool: "OperatorPool",
      in_ques: List[DataQueue],
      out_ques: List[DataQueue],
      time_profiler: "TimeProfiler",
  ):
      self._node_repr = node_repr
      self._op_pool = op_pool
      if time_profiler is None:
          self._time_profiler = TimeProfiler()
      else:
          self._time_profiler = time_profiler
      self._op = None
  
      self._in_ques = in_ques
      self._output_ques = out_ques
      self._status = NodeStatus.NOT_RUNNING
      self._need_stop = False
      self._err_msg = None
  
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 1 to create a new Node object from inherited base classes: ABC with example: obj = Node(node_repr, op_pool, in_ques, out_ques, time_profiler)