code: def test_scan_csv_no_cse_deadlock(io_files_path: Path) -> None:
      dfs = [pl.scan_csv(io_files_path / "small.csv")] * (
          pl.threadpool_size() + 1
      )
      pl.concat(dfs, parallel=True).collect(comm_subplan_elim=False)
  
imports: from __future__ import annotations
  from collections import OrderedDict
  from typing import TYPE_CHECKING
  import numpy
  import pytest
  import polars
  from polars.testing import assert_frame_equal
label_desc: Use image node_id 3 for calling a global function with example usage: test_scan_csv_no_cse_deadlock(io_files_path) without return types