code: def pipeline(redis_obj):
      p = redis_obj.pipeline()
      yield p
      p.execute()
  
file_path: catboost/contrib/python/redis/py3/redis/utils.py
imports: import logging
  import sys
  from contextlib import contextmanager
  from functools import wraps
  from typing import Any, Dict, Mapping, Union
label_desc: Use image node_id 2 for calling a global function with example usage: pipeline(redis_obj) without return types