code: def create_dvc_pipeline(tmp_dir, dvc):
      script = textwrap.dedent(
          """\
          import os, sys
          f = sys.argv[1]
          os.makedirs(os.path.dirname(f))
          open(f, "w+").close()
      """
      )
      tmp_dir.scm_gen({"script.py": script}, commit="init")
      tmp_dir.dvc_gen({"dep": "content"}, commit="init dvc")
      dvc.run(
          cmd="python script.py {}".format(os.path.join("out", "file")),
          outs=[os.path.join("out", "file")],
          deps=["dep"],
          name="touch",
      )
      tmp_dir.scm_add(["dvc.yaml", "dvc.lock"], commit="run")
      shutil.rmtree("out")
  
imports: import os
  import shutil
  import textwrap
  from operator import itemgetter
  import pytest
  from dvc.repo import Repo
  from dvc.scm import CloneError
label_desc: Use image node_id 2 for calling a global function with example usage: create_dvc_pipeline(tmp_dir, dvc) without return types