code: def test_celery_logs(
      tmp_dir,
      scm,
      dvc,
      failed_exp_stage,
      follow,
      capsys,
      test_queue,
  ):
      celery_queue = dvc.experiments.celery_queue
      dvc.experiments.run(
          failed_exp_stage.addressing, queue=True, name="foo"
      )
      dvc.experiments.run(run_all=True)
      test_queue.wait(["foo"])
  
      done_result = first(celery_queue.iter_done())
  
      name = done_result.entry.stash_rev
      captured = capsys.readouterr()
      celery_queue.logs(name, follow=follow)
      captured = capsys.readouterr()
      assert "failed to reproduce 'failed-copy-file'" in captured.out
  
imports: import pytest
  from funcy import first
label_desc: Use image node_id 2 for calling a global function with example usage: test_celery_logs(tmp_dir, scm, dvc, failed_exp_stage, follow, capsys, test_queue) without return types