code: def compression_counters():
      counters = [0, 0]
  
      def compress(v):
          counters[0] += 1
          return zlib.compress(v)
  
      def decompress(v):
          counters[1] += 1
          return zlib.decompress(v)
  
      compressions["dummy"] = Compression("dummy", compress, decompress)
      yield counters
      del compressions["dummy"]
  
imports: from __future__ import annotations
  import threading
  import zlib
  from concurrent.futures import ThreadPoolExecutor
  import pytest
  import dask.config
  from distributed import Worker, wait
  from distributed.compatibility import LINUX
  from distributed.protocol import dumps, loads, maybe_compress, msgpack, to_serialize
  from distributed.protocol.compression import Compression, compressions, get_compression_settings
  from distributed.utils import nbytes
  from distributed.utils_test import gen_cluster
label_desc: Use image node_id 2 for calling a global function with example usage: compression_counters() and returns: zlib, zlib