code: def silence_h5py_issue775(func):
      @functools.wraps(func)
      def wrapper():
          try:
              func()
          except RuntimeError as e:
              # https://github.com/h5py/h5py/issues/775
              if str(e) != "dictionary changed size during iteration":
                  raise
              tb = traceback.extract_tb(e.__traceback__)
              filename, lineno, _, _ = tb[-1]
              if not filename.endswith("h5py/_objects.pyx"):
                  raise
  
      return wrapper
  
file_path: distributed/distributed/protocol/tests/test_h5py.py
imports: from __future__ import annotations
  import functools
  import traceback
  import pytest
  from dask.utils import tmpfile
  from distributed.protocol import deserialize, serialize
  import dask.array
  from distributed.utils_test import gen_cluster
label_desc: Use image node_id 1 for calling a global function with example usage: silence_h5py_issue775(func) and returns: wrapper