code: def test_dumps_compression():
      # https://github.com/dask/distributed/issues/2966
      # large enough to trigger compression
      t = pa.Table.from_pandas(pd.DataFrame({"A": [1] * 10000}))
      msg = {"op": "update", "data": to_serialize(t)}
      result = distributed.protocol.loads(
          distributed.protocol.dumps(msg)
      )
      assert result["data"].equals(t)
  
file_path: distributed/distributed/protocol/tests/test_arrow.py
imports: from __future__ import annotations
  import pytest
  import distributed
  from distributed.protocol import deserialize, serialize, to_serialize
  from distributed.utils_test import gen_cluster
label_desc: Use image node_id 4 for calling a global function with example usage: test_dumps_compression() without return types