@threadplane/langgraphInterfacev0.3.4

AgentQueue

Public queue surface for pending server-side LangGraph runs.

View sourceView Markdown
import type { AgentQueue } from '@threadplane/langgraph';

Declaration

export interface AgentQueue<T = unknown>  {
  cancel: (id: string) => Promise<boolean>;
  clear: () => Promise<void>;
  readonly entries: ReadonlyArray<AgentQueueEntry<T>>;
  readonly size: number;
}

Type parameters

T
Default: unknown

Members

cancel

Cancel a specific pending run by server run ID.

cancel: (id: string) => Promise<boolean>;

clear

Cancel all pending runs and clear the queue.

clear: () => Promise<void>;

entries

Read-only pending queue entries.

readonly entries: ReadonlyArray<AgentQueueEntry<T>>;

size

Number of pending queue entries.

readonly size: number;