code: def test_large_bytes(dtype):
      payload = dtype(b"0" * 1000000)
      msg = {"x": to_serialize(payload), "y": 1}
      frames = dumps(msg)
      msg["x"] = msg["x"].data
      assert loads(frames) == msg
      assert len(frames[0]) < 1000
      assert len(frames[1]) < 1000
  
imports: from __future__ import annotations
  import sys
  import pytest
  from dask.sizeof import sizeof
  from distributed.compatibility import WINDOWS
  from distributed.protocol import dumps, loads, msgpack, to_serialize
  from distributed.protocol.cuda import cuda_deserialize, cuda_serialize
  from distributed.protocol.serialize import Pickled, Serialize, Serialized, ToPickle, dask_deserialize, dask_serialize, deserialize, serialize
  from distributed.utils import nbytes
  from distributed.utils_test import captured_logger
label_desc: Use image node_id 4 for calling a global function with example usage: test_large_bytes(dtype) without return types