code: def test_dont_override_default_get(loop):
      import dask.bag as db
  
      def f(x):
          with worker_client() as c:
              return True
  
      b = db.from_sequence([1, 2])
      b2 = b.map(f)
  
      with Client(
          loop=loop,
          processes=False,
          set_as_default=True,
          dashboard_address=":0",
      ) as c:
          assert dask.base.get_scheduler() == c.get
          for _ in range(2):
              b2.compute()
  
          assert dask.base.get_scheduler() == c.get
  
file_path: distributed/distributed/tests/test_worker_client.py
imports: from __future__ import annotations
  import asyncio
  import random
  import threading
  from collections import defaultdict
  from time import sleep
  import pytest
  import dask
  from dask import delayed
  from distributed import Client, as_completed, get_client, get_worker, wait, worker_client
  from distributed.metrics import time
  from distributed.utils_test import double, gen_cluster, inc, slowinc
label_desc: Use image node_id 2 for calling a global function with example usage: test_dont_override_default_get(loop) and returns: True