code: def test_maybe_compress(compression, dtype):
      payload = dtype(b"123")
      assert maybe_compress(payload, compression=compression) == (
          None,
          payload,
      )
  
      payload = dtype(b"0" * 10000)
      rc, rd = maybe_compress(payload, compression=compression)
      assert rc == compression
      assert compressions[rc].decompress(rd) == payload
  
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 10 for calling a global function with example usage: test_maybe_compress(compression, dtype) without return types