code: def test_put_local_get(ray_start_regular):
      chan = ray_channel.Channel(1000)
  
      num_writes = 1000
      for i in range(num_writes):
          val = i.to_bytes(8, "little")
          chan.write(val, num_readers=1)
          assert chan.begin_read() == val
  
          # Begin read multiple times will return the same value.
          assert chan.begin_read() == val
  
          chan.end_read()
  
file_path: ray/python/ray/tests/test_channel.py
imports: import logging
  import os
  import sys
  import numpy
  import pytest
  import ray
  import ray.cluster_utils
  import ray.experimental.channel
label_desc: Use image node_id 1 for calling a global function with example usage: test_put_local_get(ray_start_regular) without return types