code: def get_pipeline(operator: str, tag: str, latest: bool = False):
      return _CACHE_MANAGER.get_pipeline(operator, tag, latest)
  
imports: from .cache_manager import CacheManager, set_local_dir
  from .downloader import set_hub_url
label_desc: Use image node_id 2 for calling a global function with example usage: get_pipeline(operator, tag, latest) and returns: _CACHE_MANAGER