code: def session_app(tmp_path_factory) -> FSApp:
      """Session scoped experiments queue celery app."""
      from kombu.transport.filesystem import Channel
  
      # related to https://github.com/iterative/dvc-task/issues/61
      Channel.QoS.restore_at_shutdown = False
  
      from dvc_task.app import FSApp
  
      wdir = tmp_path_factory.mktemp("dvc-test-celery")
      app = FSApp(
          "dvc-exp-local",
          wdir=wdir,
          mkdir=True,
          include=[
              "dvc.repo.experiments.queue.tasks",
              "dvc_task.proc.tasks",
          ],
      )
      app.conf.update({"task_acks_late": True, "result_expires": None})
      return app
  
file_path: dvc/tests/unit/repo/experiments/conftest.py
imports: from functools import partial
  import pytest
  from dvc_task.app import FSApp
label_desc: Use image node_id 4 for calling a global function with example usage: session_app(tmp_path_factory) and returns: app