Functional API 개요

import { MemorySaver, entrypoint, task, interrupt } from "@langchain/langgraph";

const writeEssay = task("writeEssay", async (topic: string) => {
  // 장시간 실행되는 작업의 플레이스홀더입니다.
  await new Promise((resolve) => setTimeout(resolve, 1000));
  return `An essay about topic: ${topic}`;
});

const workflow = entrypoint(
  { checkpointer: new MemorySaver(), name: "workflow" },
  async (topic: string) => {
    const essay = await writeEssay(topic);
    const isApproved = interrupt({
      // interrupt에 인자로 제공되는 모든 json 직렬화 가능한 페이로드입니다.
      // 워크플로에서 데이터를 스트리밍할 때 클라이언트 측에서 Interrupt로 표시됩니다.
      essay, // 검토를 원하는 에세이입니다.
      // 필요한 추가 정보를 추가할 수 있습니다.
      // 예를 들어, 일부 지침과 함께 "action"이라는 키를 도입합니다.
      action: "Please approve/reject the essay",
    });

    return {
      essay, // 생성된 에세이
      isApproved, // HIL의 응답
    };
  }
);

import { entrypoint } from "@langchain/langgraph";

const myWorkflow = entrypoint(
  { checkpointer, name: "workflow" },
  async (someInput: Record<string, any>): Promise<number> => {
    // API 호출과 같은 장시간 실행되는 작업을 포함할 수 있는 일부 로직이며,
    // human-in-the-loop을 위해 중단될 수 있습니다.
    return result;
  }
);

import { entrypoint, getPreviousState } from "@langchain/langgraph";

const myWorkflow = entrypoint(
  { checkpointer, name: "workflow" },
  async (number: number) => {
    const previous = getPreviousState<number>() ?? 0;
    return number + previous;
  }
);

const config = {
  configurable: {
    thread_id: "some_thread_id",
  },
};

await myWorkflow.invoke(1, config); // 1 (previous는 undefined였습니다)
await myWorkflow.invoke(2, config); // 3 (previous는 이전 호출의 1이었습니다)

import { entrypoint, getPreviousState } from "@langchain/langgraph";

const myWorkflow = entrypoint(
  { checkpointer, name: "workflow" },
  async (number: number) => {
    const previous = getPreviousState<number>() ?? 0;
    // 호출자에게 previous 값을 반환하고,
    // 2 * number를 체크포인트에 저장합니다. 이는 다음 호출의
    // `previous` 매개변수에 사용됩니다.
    return entrypoint.final({
      value: previous,
      save: 2 * number,
    });
  }
);

const config = {
  configurable: {
    thread_id: "1",
  },
};

await myWorkflow.invoke(3, config); // 0 (previous는 undefined였습니다)
await myWorkflow.invoke(1, config); // 6 (previous는 이전 호출의 3 * 2였습니다)

import { task } from "@langchain/langgraph";

const slowComputation = task("slowComputation", async (inputValue: any) => {
  // 장시간 실행되는 작업을 시뮬레이션합니다.
  return result;
});

const myWorkflow = entrypoint(
  { checkpointer, name: "workflow" },
  async (someInput: number): Promise<number> => {
    return await slowComputation(someInput);
  }
);