code: def read_chunk(fobj, off, l, head):
      """Get rows from raw bytes block"""
      import fastavro
  
      if hasattr(fastavro, "iter_avro"):
          reader = fastavro.iter_avro
      else:
          reader = fastavro.reader
  
      with fobj as f:
          chunk = read_block(f, off, l, head["sync"])
      head_bytes = head["head_bytes"]
      if not chunk.startswith(MAGIC):
          chunk = head_bytes + chunk
      i = io.BytesIO(chunk)
      return list(reader(i))
  
file_path: dask/dask/bag/avro.py
imports: from __future__ import annotations
  import io
  import uuid
  from fsspec.core import OpenFile, get_fs_token_paths, open_files
  from fsspec.utils import read_block
  from fsspec.utils import tokenize
  from dask.highlevelgraph import HighLevelGraph
label_desc: Use image node_id 6 for calling a global function with example usage: read_chunk(fobj, off, l, head) and returns: list