code: def test_loads_without_deserialization_avoids_compression():
      b = b"0" * 100000
  
      msg = {"x": 1, "data": to_serialize(b)}
      frames = dumps(msg, context={"compression": "zlib"})
  
      assert sum(map(nbytes, frames)) < 10000
  
      msg2 = loads(frames, deserialize=False)
      assert sum(map(nbytes, msg2["data"].frames)) < 10000
  
      msg3 = dumps(msg2, context={"compression": "zlib"})
      msg4 = loads(msg3)
  
      assert msg4 == {"x": 1, "data": b"0" * 100000}
  
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 16 for calling a global function with example usage: test_loads_without_deserialization_avoids_compression() without return types