@spec await(ElGraph.Runner.Run.t(), timeout()) ::
  ElGraph.Executor.result() | {:error, term()}

실행 결과를 기다린다. 러너가 비정상 종료하면 {:error, :killed} 등을 반환한다.

@spec cancel(
  ElGraph.Runner.Run.t(),
  keyword()
) :: :ok

실행을 취소한다. 취소 플래그를 세우고 러너 종료를 기다리며, :cancel_timeout(기본 5초) 안에 끝나지 않으면 brutal kill 한다.

@spec list(atom()) :: [
  %{
    thread_id: String.t(),
    pid: pid(),
    step: non_neg_integer(),
    active: [atom()]
  }
]

Registry에 등록된 실행 중 thread 목록 (introspection, SPEC §3.4 / 부록 A-1).

start_run/3에 :registry 옵션을 준 실행만 나타나며, 실행 프로세스가 죽으면 Registry가 자동 정리한다.

@spec peek(atom(), String.t()) ::
  {:ok, %{pid: pid(), step: non_neg_integer(), active: [atom()]}} | :not_found

실행 중인 thread의 현재 진행 상황: {:ok, %{pid:, step:, active:}} 또는 :not_found.

@spec start_resume(
  ElGraph.Graph.t(),
  keyword()
) :: {:ok, ElGraph.Runner.Run.t()}

체크포인트 재개를 별도 프로세스(nolink + monitor)로 시작한다.

ElGraph.resume/2의 비동기 버전 — 에이전트의 crash-only 복구(SPEC §5)에 쓰인다.

@spec start_run(ElGraph.Graph.t(), map() | keyword(), keyword()) ::
  {:ok, ElGraph.Runner.Run.t()}

그래프 실행을 별도 프로세스(nolink + monitor)로 시작한다.