code: def download_operator(
      author: str,
      repo: str,
      tag: str,
      op_path: Path,
      install_reqs: bool = True,
      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 op {}/{}:{} info failed".format(author, repo, tag)
          )
      fs = _HubFiles(op_path, tag, meta)
      _Downloader(fs).download()
      fs.symlink_files(latest)
  
      if install_reqs and fs.requirements:
          subprocess.check_call(
              [
                  sys.executable,
                  "-m",
                  "pip",
                  "install",
                  "-r",
                  str(fs.requirements),
              ]
          )
  
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 3 for calling a global function with example usage: download_operator(author, repo, tag, op_path, install_reqs, latest) without return types