code: def download_pipeline(
      author: str,
      repo: str,
      tag: str,
      pipe_path: Path,
      latest: bool = False,
  ):
      hub_url = get_hub_url()
      ht = HubUtils(author, repo, hub_url)
      meta = ht.branch_tree(tag)
      if meta is None:
          raise RuntimeError(
              "Fetch pipeline {}/{}:{} info failed".format(
                  author, repo, tag
              )
          )
      fs = _HubFiles(pipe_path, tag, meta)
      _Downloader(fs).download()
      fs.symlink_files(latest)
  
imports: import os
  import sys
  import tempfile
  import shutil
  from pathlib import Path
  from concurrent.futures import ThreadPoolExecutor
  import subprocess
  import requests
  from tqdm import tqdm
  from tenacity import retry, stop_after_attempt, wait_random_exponential
  from towhee.utils.hub_utils import HubUtils
label_desc: Use image node_id 4 for calling a global function with example usage: download_pipeline(author, repo, tag, pipe_path, latest) without return types