code: def blocked_inc(x, event):
      event.wait()
      return x + 1
  
file_path: distributed/distributed/tests/test_cluster_dump.py
imports: from __future__ import annotations
  import asyncio
  from pathlib import Path
  import fsspec
  import msgpack
  import pytest
  import yaml
  import distributed
  from distributed.cluster_dump import DumpArtefact, _tuple_to_list, write_state
  from distributed.utils_test import assert_story, gen_cluster, gen_test, inc
label_desc: Use image node_id 2 for calling a global function with example usage: blocked_inc(x, event) and returns: unknown