code: def test_collect_yaml_malformed_file(tmpdir):
      dir_path = str(tmpdir)
      fil_path = os.path.join(dir_path, "a.yaml")
  
      with open(fil_path, mode="wb") as f:
          f.write(b"{")
  
      with pytest.raises(ValueError) as rec:
          collect_yaml(paths=[dir_path])
      assert repr(fil_path) in str(rec.value)
      assert "is malformed" in str(rec.value)
      assert "original error message" in str(rec.value)
  
imports: from __future__ import annotations
  import os
  import site
  import stat
  import sys
  from collections import OrderedDict
  from contextlib import contextmanager
  import pytest
  import yaml
  import dask.config
  from dask.config import _get_paths, canonical_name, collect, collect_env, collect_yaml, config, deserialize, ensure_file, expand_environment_variables, get, merge, pop, refresh, rename, serialize, update, update_defaults
  from dask.utils import tmpfile
label_desc: Use image node_id 12 for calling a global function with example usage: test_collect_yaml_malformed_file(tmpdir) without return types