code: def test_completion_check() -> None:
      with parallel.Execution(2) as pex:
  
          @pex.run
          def do_test() -> None:
              searcher = make_test_searcher([5], pex.distributed)
  
              ops = iter(searcher.operations())
              next(ops)
              # Don't complete the op.
              with parallel.raises_when(
                  pex.rank == 0,
                  RuntimeError,
                  match="must call op.report_completed",
              ):
                  next(ops)
              # Wake up worker manually; it is hung waiting for the now-failed chief.
              if pex.rank == 0:
                  pex.distributed.broadcast(10)
  
file_path: determined/harness/tests/core/test_searcher.py
imports: from typing import Any, List
  from unittest import mock
  import pytest
  from determined import core
  from tests import parallel
label_desc: Use image node_id 3 for calling a global function with example usage: test_completion_check() without return types