code: def _remove_all_progress_plugin(self, *args, **kwargs):
      # Wrapper function around `Scheduler.remove_plugin` to avoid raising a
      # `PicklingError` when using a cythonized scheduler
      self.remove_plugin(name=AllProgress.name)
  
file_path: distributed/distributed/diagnostics/progress_stream.py
imports: from __future__ import annotations
  import logging
  from tlz import merge, valmap
  from dask.utils import key_split
  from distributed.core import coerce_to_address, connect
  from distributed.diagnostics.progress import AllProgress
  from distributed.utils import color_of
  from distributed.worker import dumps_function
label_desc: Use image node_id 2 for calling a global function with example usage: _remove_all_progress_plugin() without return types