class_docstr: Pipeline is a tool to create data transformation chains.
  
  Args:
      dag (`dict`): The dag for the pipeline.
      clo_node (`str`): The close node in the pipeline dag, defaults to '_input'.
code: def _to_action(fn):
      if fn in [OPName.NOP, ConcatConst.name]:
          return OperatorAction.from_builtin(fn)
      if isinstance(fn, _OperatorWrapper):
          return OperatorAction.from_hub(
              fn.name, fn.init_args, fn.init_kws, fn.tag, fn.is_latest
          )
      if isinstance(fn, RuntimePipeline):
          return OperatorAction.from_pipeline(fn)
      if getattr(fn, "__name__", None) == "<lambda>":
          return OperatorAction.from_lambda(fn)
      if callable(fn):
          return OperatorAction.from_callable(fn)
      raise ValueError(
          "Unknown operator, please make sure it is lambda, callable or operator with ops."
      )
  
imports: import uuid
  from copy import deepcopy
  from towhee.runtime.check_utils import TupleForm
  from towhee.runtime.operator_manager import OperatorAction
  from towhee.runtime.factory import _OperatorWrapper
  from towhee.runtime.runtime_pipeline import RuntimePipeline
  from towhee.runtime.constants import MapConst, WindowAllConst, WindowConst, ReduceConst, FilterConst, TimeWindowConst, FlatMapConst, ConcatConst, InputConst, OutputConst, OPName
label_desc: Use image node_id 13 for calling the Pipeline obj's underlying member method code with example usage: obj._to_action(fn) and returns: OperatorAction, OperatorAction, OperatorAction, OperatorAction, OperatorAction