Google ADK에서 마이그레이션하기

from google.adk.agents import LlmAgent, SequentialAgent
from google.adk.tools import FunctionTool

def web_search(query: str) -> dict:
    """Searches the web for information on the given query."""
    # Implementation
    return {"results": ["result 1", "result 2"]}

search_agent = LlmAgent(
    name="searcher",
    model="gemini-2.5-flash",
    instruction="Search for: {query}",
    tools=[web_search],
    output_key="search_results",
)

analyst = LlmAgent(
    name="analyst",
    model="gemini-2.5-pro",
    instruction=(
        "Analyze these results: {search_results}. "
        "Write a comprehensive summary with key findings."
    ),
    output_key="summary",
)

pipeline = SequentialAgent(
    name="research_assistant",
    sub_agents=[search_agent, analyst],
)

# 파이프라인 실행하기

from google.adk.runners import Runner
from google.adk.sessions import InMemorySessionService
from google.genai import types

runner = Runner(
    agent=pipeline,
    app_name="research_app",
    session_service=InMemorySessionService(),
)

session = runner.session_service.create_session(
    app_name="research_app", user_id="user1"
)

events = runner.run(
    user_id="user1",
    session_id=session.id,
    new_message=types.Content(
        parts=[types.Part(text="내구성 있는 AI 워크플로 오케스트레이션")]
    ),
)

for event in events:
    if event.is_final_response():
        print(event.content.parts[0].text)

id: research-assistant
version: "0.1.0"

nodes:
  search:
    type: tool
    server: brave-search
    tool: web_search
    arguments:
      query: "{{ state.query }}"
    output_key: search_results
    retry:
      max_attempts: 3
      backoff: exponential
    next: analyze

  analyze:
    type: model
    model: claude-sonnet-4-6
    prompt: |
      다음 검색 결과를 분석하세요: {{ state.search_results }}.
      주요 발견사항을 포함한 포괄적인 요약을 작성하세요.
    output_key: summary
    next: evaluate

  evaluate:
    type: eval
    scorers:
      - type: llm_judge
        model: claude-haiku-4-5-20251001
        rubric: "요약이 정확하고 체계적이며 포괄적인가?"
    fail_under: 4.0

from openai import OpenAI
from pydantic import BaseModel
from jamjet import Workflow

client = OpenAI()

class State(BaseModel):
    query: str
    search_results: str = ""
    summary: str = ""

wf = Workflow("research-assistant")

@wf.state
class ResearchState(State):
    pass

@wf.step
async def search(state: ResearchState) -> ResearchState:
    # 프로덕션 환경: type: tool + MCP 서버가 이를 처리
    results = f"[검색 결과: {state.query}]"
    return state.model_copy(update={"search_results": results})

@wf.step
async def analyze(state: ResearchState) -> ResearchState:
    resp = client.chat.completions.create(
        model="gpt-4o-mini",
        messages=[
            {"role": "system", "content": (
                "당신은 전문 리서치 분석가입니다. "
                "주요 발견사항을 포함한 포괄적인 요약을 작성하세요."
            )},
            {"role": "user", "content": (
                f"다음 결과를 분석하세요: {state.search_results}"
            )},
        ],
    )
    return state.model_copy(update={"summary": resp.choices[0].message.content or ""})

result = wf.run_sync(ResearchState(query="내구성 있는 AI 워크플로 오케스트레이션"))
print(result.state.summary)

# ADK: 모든 것이 허용됨

session.state["results"] = 42      # 리스트여야 하는 거 아니었나?
session.state["resutls"] = [...]   # 오타 — 오류 없음, 조용한 버그

# JamJet: 즉시 포착됨

class State(BaseModel):
    results: list[str] = []

state.model_copy(update={"results": 42})  # ValidationError

# 과거 실행 리플레이

jamjet replay exec-abc123

# 특정 단계에서 분기하여 다른 경로 시도

jamjet replay exec-abc123 --fork-at analyze

# ADK: 도구가 에이전트 코드 내부에 존재

# def web_search(query: str) -> dict:

#     """웹을 검색합니다."""

# JamJet: 도구는 독립적인 MCP 서버

nodes:
  search:
    type: tool
    server: brave-search      # 모든 MCP 호환 서버
    tool: web_search
    arguments:
      query: "{{ state.query }}"
    retry:
      max_attempts: 3
      backoff: exponential

jamjet eval run evals/research.jsonl \
  --workflow research-assistant \
  --fail-under 0.85

nodes:
  fast-search:
    type: model
    model: claude-haiku-4-5-20251001     # Anthropic
    # ...

  deep-analysis:
    type: model
    model: gpt-4o              # OpenAI
    # ...

  local-draft:
    type: model
    model: ollama/llama3       # Local
    # ...

pip install jamjet