code: def test_resolve_block_refs(ray_start_regular_shared):
      block_refs = [ray.put(0), ray.put(1), ray.put(2)]
  
      resolved_iter = resolve_block_refs(iter(block_refs))
      assert list(resolved_iter) == [0, 1, 2]
  
imports: import threading
  import time
  import numpy
  import pandas
  import pyarrow
  import pytest
  import ray
  from ray.data._internal.block_batching.interfaces import Batch
  from ray.data._internal.block_batching.util import _calculate_ref_hits, blocks_to_batches, collate, finalize_batches, format_batches, resolve_block_refs
  from ray.data._internal.util import Queue, make_async_gen
label_desc: Use image node_id 2 for calling a global function with example usage: test_resolve_block_refs(ray_start_regular_shared) without return types