code: def _thread_worker(app, **kwargs):
      # Based on pytest-celery's celery_worker fixture but using thread pool
      # instead of solo pool so that broadcast/control API is available
      from celery.contrib.testing import worker
  
      app.loader.import_task_module("celery.contrib.testing.tasks")
      return worker.start_worker(app, pool="threads", **kwargs)
  
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 3 for calling a global function with example usage: _thread_worker(app) and returns: worker