code: def session_worker(session_app):
      """Session scoped celery worker that runs in separate thread(s)."""
      with _thread_worker(
          session_app,
          concurrency=1,
          ping_task_timeout=20,
          loglevel="DEBUG",
      ) as worker:
          yield worker
  
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 5 for calling a global function with example usage: session_worker(session_app) without return types