code: def test_roundtrip(obj):
      # Test that the serialize/deserialize functions actually
      # work independent of distributed
      header, frames = serialize(obj)
      new_obj = deserialize(header, frames)
      assert obj.equals(new_obj)
  
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 1 for calling a global function with example usage: test_roundtrip(obj) without return types