code: def test_progress_quads_too_many():
      keys = ["x-%d" % i for i in range(1000)]
      msg = {
          "all": {k: 1 for k in keys},
          "memory": {k: 0 for k in keys},
          "erred": {k: 0 for k in keys},
          "released": {k: 0 for k in keys},
          "processing": {k: 0 for k in keys},
          "queued": {k: 0 for k in keys},
      }
  
      d = progress_quads(msg, nrows=6, ncols=3)
      assert len(d["name"]) == 6 * 3
  
file_path: distributed/distributed/diagnostics/tests/test_progress_stream.py
imports: from __future__ import annotations
  import pytest
  from dask import delayed
  from distributed.client import wait
  from distributed.diagnostics.progress_stream import progress_quads, progress_stream
  from distributed.utils_test import div, gen_cluster, inc
label_desc: Use image node_id 2 for calling a global function with example usage: test_progress_quads_too_many() without return types