code: def test_onefile_oneblock(tmpdir):
      tmpdir = str(tmpdir)
      fn = os.path.join(tmpdir, "one.avro")
      with open(fn, "wb") as f:
          fastavro.writer(f, records=expected, schema=schema)
      b = db.read_avro(fn, blocksize=None)
      assert b.npartitions == 1
      assert b.compute() == expected
  
file_path: dask/dask/bag/tests/test_avro.py
imports: from __future__ import annotations
  import os
  import random
  import pytest
  import dask.bag
label_desc: Use image node_id 1 for calling a global function with example usage: test_onefile_oneblock(tmpdir) without return types