code: def _wait_on_futures(futures):
      for fut in futures:
          try:
              yield fut
          except Exception:
              pass
  
file_path: distributed/distributed/cfexecutor.py
imports: from __future__ import annotations
  import concurrent.futures
  import weakref
  from tlz import merge
  from tornado import gen
  from dask.utils import parse_timedelta
  from distributed.metrics import time
  from distributed.utils import TimeoutError, sync
label_desc: Use image node_id 2 for calling a global function with example usage: _wait_on_futures(futures) without return types