code: def test_maybe_compress_auto():
      np = pytest.importorskip("numpy")
      x = np.arange(1000000, dtype="int64")
      compression, payload = maybe_compress(x.data)
      assert compression == compressions["auto"].name
      assert len(payload) < x.nbytes * 0.75
  
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 13 for calling a global function with example usage: test_maybe_compress_auto() without return types