code: def test_fast(client):
      L = client.map(inc, range(100))
      L2 = client.map(dec, L)
      L3 = client.map(add, L, L2)
      p = progress(L3, multi=True, complete=True, notebook=True)
      client.sync(p.listen)
      assert set(p._last_response["all"]) == {"inc", "dec", "add"}
  
file_path: distributed/distributed/diagnostics/tests/test_progress_widgets.py
imports: from __future__ import annotations
  import re
  from operator import add
  import pytest
  from dask.utils import key_split
  from distributed.client import wait
  from distributed.spans import span
  from distributed.utils_test import dec, gen_cluster, gen_tls_cluster, inc, throws
  from distributed.diagnostics.progressbar import MultiProgressWidget, ProgressWidget, progress
label_desc: Use image node_id 4 for calling a global function with example usage: test_fast(client) without return types