code: def test_import_with_jobs(mocker, dvc, erepo_dir):
      import dvc_data.hashfile.transfer as otransfer
  
      with erepo_dir.chdir():
          erepo_dir.dvc_gen(
              {
                  "dir1": {
                      "file1": "file1",
                      "file2": "file2",
                      "file3": "file3",
                      "file4": "file4",
                  }
              },
              commit="init",
          )
  
      spy = mocker.spy(otransfer, "transfer")
      dvc.imp(os.fspath(erepo_dir), "dir1", jobs=3)
      # the first call will be retrieving dir cache for "dir1" w/jobs None
      for _args, kwargs in spy.call_args_list[1:]:
          assert kwargs.get("jobs") == 3
  
imports: import filecmp
  import os
  import pytest
  from funcy import first
  from dvc.cachemgr import CacheManager
  from dvc.config import NoRemoteError
  from dvc.dvcfile import load_file
  from dvc.fs import system
  from dvc.scm import Git
  from dvc.stage.exceptions import StagePathNotFoundError
  from dvc.testing.tmp_dir import make_subrepo
  from dvc.utils.fs import remove
  from dvc_data.index.index import DataIndexDirError
label_desc: Use image node_id 32 for calling a global function with example usage: test_import_with_jobs(mocker, dvc, erepo_dir) without return types