This commit is contained in:
2026-06-04 16:41:50 +00:00
parent 03febd4b7d
commit a0aa75a7f8
+22 -22
View File
@@ -1,34 +1,33 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
""" """
CLI для агента с рефлексией на LangGraph CLI для агента с retry через try/except
Демонстрирует цикл: draft → reflect → (rewrite → reflect) → END Демонстрирует цикл: generate → валидация → (retry при ошибке) → END
""" """
import argparse import argparse
import sys import sys
from graph import build_reflection_graph from graph import build_retry_graph
from state import ReflectState from state import ReflectState
DEMO_QUESTION = "Объясни студенту разницу между tool и resource в MCP" DEMO_QUESTION = "Объясни студенту разницу между tool и resource в MCP"
def run_agent(question: str, max_rounds: int = 2, verbose: bool = True): def run_agent(question: str, max_rounds: int = 3, verbose: bool = True):
"""Запускает агента с рефлексией""" """Запускает агента с retry-логикой"""
if verbose: if verbose:
print("\n" + "="*80) print("\n" + "="*80)
print(f"🤖 ЗАПУСК АГЕНТА С РЕФЛЕКСИЕЙ") print(f"🤖 ЗАПУСК АГЕНТА С RETRY (TRY/EXCEPT)")
print(f"📋 Вопрос: {question}") print(f"📋 Вопрос: {question}")
print(f"🔄 Макс. раундов: {max_rounds}") print(f"🔄 Макс. попыток: {max_rounds}")
print("="*80) print("="*80)
# Создаём граф # Создаём граф
app = build_reflection_graph(max_rounds=max_rounds) app = build_retry_graph(max_rounds=max_rounds)
# Состояние # Состояние
initial_state: ReflectState = { initial_state: ReflectState = {
"question": question, "question": question,
"draft": "", "draft": "",
"critique": "", "error": None,
"verdict": "needs_revision", # Начальное значение
"round": 1, "round": 1,
"max_rounds": max_rounds "max_rounds": max_rounds
} }
@@ -39,23 +38,25 @@ def run_agent(question: str, max_rounds: int = 2, verbose: bool = True):
# Вывод # Вывод
if verbose: if verbose:
print("\n" + "="*80) print("\n" + "="*80)
if final_state["error"] is None:
print("✅ ФИНАЛЬНЫЙ РЕЗУЛЬТАТ") print("✅ ФИНАЛЬНЫЙ РЕЗУЛЬТАТ")
print("="*80) print("="*80)
print(f"📝 Итоговый ответ (раунд {final_state['round']}):") print(f"📝 Итоговый ответ (попытка {final_state['round']}):")
print("-"*80) print("-"*80)
print(final_state["draft"]) print(final_state["draft"])
print("-"*80) print("-"*80)
print(f"🎉 Успешно сгенерировано за {final_state['round']} попыток!")
if final_state["verdict"] == "ok":
print("🎉 Ответ одобрен критиком!")
else: else:
print(f"⚠️ Достигнут лимит раундов ({max_rounds}), но вердикт: {final_state['verdict']}") print("❌ ОШИБКА ГЕНЕРАЦИИ")
print("="*80)
print(f"Достигнут лимит попыток ({max_rounds})")
print(f"Последняя ошибка: {final_state['error']}")
return final_state return final_state
def interactive_mode(): def interactive_mode():
"""Интерактивный режим""" """Интерактивный режим"""
print("\n🎮 Интерактивный режим агента с рефлексией") print("\n🎮 Интерактивный режим агента с retry (try/except)")
print("Введите 'exit' для выхода\n") print("Введите 'exit' для выхода\n")
while True: while True:
@@ -65,27 +66,27 @@ def interactive_mode():
if not question: if not question:
continue continue
max_rounds = input("Макс. раундов (по умолч. 2): ").strip() max_rounds = input("Макс. попыток (по умолч. 3): ").strip()
max_rounds = int(max_rounds) if max_rounds.isdigit() else 2 max_rounds = int(max_rounds) if max_rounds.isdigit() else 3
run_agent(question, max_rounds, verbose=True) run_agent(question, max_rounds, verbose=True)
print("\n" + ""*80 + "\n") print("\n" + ""*80 + "\n")
def main(): def main():
parser = argparse.ArgumentParser( parser = argparse.ArgumentParser(
description="LangGraph агент с рефлексией и доработкой ответов", description="LangGraph агент с retry через try/except",
formatter_class=argparse.RawDescriptionHelpFormatter, formatter_class=argparse.RawDescriptionHelpFormatter,
epilog=""" epilog="""
Примеры: Примеры:
python cli.py --demo # Запуск на демо-вопросе python cli.py --demo # Запуск на демо-вопросе
python cli.py -q "Что такое AI?" # Свой вопрос python cli.py -q "Что такое AI?" # Свой вопрос
python cli.py -q "..." --max-rounds 3 # 3 раунда доработки python cli.py -q "..." --max-rounds 5 # 5 попыток
python cli.py --interactive # Интерактивный режим python cli.py --interactive # Интерактивный режим
""" """
) )
parser.add_argument("-q", "--question", help="Вопрос для агента") parser.add_argument("-q", "--question", help="Вопрос для агента")
parser.add_argument("--max-rounds", type=int, default=2, help="Макс. раундов доработки (по умолч. 2)") parser.add_argument("--max-rounds", type=int, default=3, help="Макс. попыток (по умолч. 3)")
parser.add_argument("--demo", action="store_true", help="Запустить демо-вопрос") parser.add_argument("--demo", action="store_true", help="Запустить демо-вопрос")
parser.add_argument("-i", "--interactive", action="store_true", help="Интерактивный режим") parser.add_argument("-i", "--interactive", action="store_true", help="Интерактивный режим")
parser.add_argument("--quiet", action="store_true", help="Тихий режим (только ответ)") parser.add_argument("--quiet", action="store_true", help="Тихий режим (только ответ)")
@@ -95,7 +96,6 @@ def main():
if args.interactive: if args.interactive:
interactive_mode() interactive_mode()
elif args.demo or (not args.question): elif args.demo or (not args.question):
# Демо-режим
run_agent(DEMO_QUESTION, args.max_rounds, verbose=not args.quiet) run_agent(DEMO_QUESTION, args.max_rounds, verbose=not args.quiet)
elif args.question: elif args.question:
run_agent(args.question, args.max_rounds, verbose=not args.quiet) run_agent(args.question, args.max_rounds, verbose=not args.quiet)