code: def read_from_disk(path: Path) -> tuple[list[pa.Table], int]:
      import pyarrow as pa
  
      batch_size = parse_bytes("1 MiB")
      batch = []
      shards = []
  
      with pa.OSFile(str(path), mode="rb") as f:
          size = f.seek(0, whence=2)
          f.seek(0)
          prev = 0
          offset = f.tell()
          while offset < size:
              sr = pa.RecordBatchStreamReader(f)
              shard = sr.read_all()
              offset = f.tell()
              batch.append(shard)
  
              if offset - prev >= batch_size:
                  table = concat_tables(batch)
                  shards.append(_copy_table(table))
                  batch = []
                  prev = offset
      if batch:
          table = concat_tables(batch)
          shards.append(_copy_table(table))
      return shards, size
  
file_path: distributed/distributed/shuffle/_arrow.py
imports: from __future__ import annotations
  from collections.abc import Iterable
  from pathlib import Path
  from typing import TYPE_CHECKING
  from packaging.version import parse
  from dask.utils import parse_bytes
label_desc: Use image node_id 8 for calling a global function with example usage: read_from_disk(path) and returns: shards,  size