code: def test_celery_queue_failure_status(
      dvc, scm, test_queue, failed_exp_stage
  ):
      queue_entry = test_queue._stash_exp(
          params={"params.yaml": ["foo=1"]},
          targets=failed_exp_stage.addressing,
          name="failed",
      )
      infofile = test_queue.get_infofile_path(queue_entry.stash_rev)
      setup_exp.s(queue_entry.asdict())()
      cmd = ["dvc", "exp", "exec-run", "--infofile", infofile]
      test_queue.proc.run_signature(cmd, name=queue_entry.stash_rev)()
      executor_info = ExecutorInfo.load_json(infofile)
      assert executor_info.status == TaskStatus.FAILED
  
file_path: dvc/tests/unit/repo/experiments/test_executor_status.py
imports: import os
  import pytest
  from dvc.exceptions import ReproductionError
  from dvc.repo.experiments.executor.base import ExecutorInfo, TaskStatus
  from dvc.repo.experiments.queue.tasks import cleanup_exp, collect_exp, setup_exp
label_desc: Use image node_id 2 for calling a global function with example usage: test_celery_queue_failure_status(dvc, scm, test_queue, failed_exp_stage) without return types