mirror of
https://github.com/langchain-ai/langgraph.git
synced 2026-08-21 23:22:27 +02:00
11 KiB
11 KiB
In [1]:
from operator import itemgetter
from langchain.chat_models.openai import ChatOpenAI
from langchain.prompts import SystemMessagePromptTemplate
from langchain.schema.output_parser import StrOutputParser
from langchain.runnables.openai_functions import OpenAIFunctionsRouter
from permchain.connection_inmemory import InMemoryPubSubConnection
from permchain.pubsub import PubSub
from permchain.topic import TopicIn [2]:
drafter_prompt = (
SystemMessagePromptTemplate.from_template(
"You are an expert on turtles, who likes to write in pirate-speak. You have been tasked by your editor with drafting a 100-word article answering the following question."
)
+ "Question:\n\n{question}"
)
drafter_llm = ChatOpenAI(model="gpt-3.5-turbo")
drafter = drafter_prompt | drafter_llm | StrOutputParser()In [3]:
drafter.invoke({"question": "what is art?"})Out [3]:
"Arrr, me hearty! Art be a thing of beauty and expression, me hearties! It be a way for a scurvy dog to convey their innermost thoughts and feelings through visual, auditory, or kinesthetic means. It be a form of communication that ye can't be puttin' into words, but ye can feel it in yer bones. Art be a treasure that be created by the talents and imaginations of landlubbers. Whether it be a paintin', a sculpture, a song, or a dance, art be a way to celebrate the wonders of this here world and let yer soul run wild on the high seas of creativity."
In [4]:
editor_prompt = (
SystemMessagePromptTemplate.from_template(
"You are an editor. You have been tasked with editing the following draft, which was written by a non-expert. Please accept the draft if it is good enough to publish, or send it for revision, along with your notes to guide the revision."
)
+ "Draft:\n\n{draft}"
)
editor_llm = ChatOpenAI(model="gpt-4")
functions = [
{
"name": "revise",
"description": "Sends the draft for revision",
"parameters": {
"type": "object",
"properties": {
"notes": {
"type": "string",
"description": "The editor's notes to guide the revision.",
},
},
},
},
{
"name": "accept",
"description": "Accepts the draft",
"parameters": {
"type": "object",
"properties": {"ready": {"const": True}},
},
},
]
editor = editor_prompt | editor_llm.bind(functions=functions)In [5]:
editor.invoke({"draft": "hi!"})Out [5]:
AIMessage(content='', additional_kwargs={'function_call': {'name': 'revise', 'arguments': '{\n "notes": "The draft is too short and lacks content. Please provide more information or expand on your current topic."\n}'}}, example=False)In [6]:
reviser_prompt = (
SystemMessagePromptTemplate.from_template(
"You are an expert on turtles. You have been tasked by your editor with revising the following draft, which was written by a non-expert. You may follow the editor's notes or not, as you see fit."
)
+ "Draft:\n\n{draft}"
+ "Editor's notes:\n\n{notes}"
)
reviser_llm = ChatOpenAI(model="gpt-3.5-turbo")
reviser = reviser_prompt | reviser_llm | StrOutputParser()In [7]:
reviser.invoke({"draft": "hi!", "notes": "too short"})Out [7]:
'Revised Draft:\n\nHello there!'
In [8]:
# create topics
editor_inbox = Topic("editor_inbox")
reviser_inbox = Topic("reviser_inbox")In [9]:
draft_chain = (
# Listed in inputs
Topic.IN.subscribe()
| {"draft": drafter}
# The draft always goes to the editors inbox
| editor_inbox.publish()
)In [10]:
editor_chain = (
# Listen for events in the editors inbox
editor_inbox.subscribe()
| editor
# Depending on the output, different things should happen
| OpenAIFunctionsRouter(
{
# If revise is chosen, we send a push to the revisor's inbox
"revise": (
{
"notes": itemgetter("notes"),
"draft": editor_inbox.current() | itemgetter("draft"),
"question": Topic.IN.current() | itemgetter("question"),
}
| reviser_inbox.publish()
),
# If accepted, then we return
"accept": editor_inbox.current() | Topic.OUT.publish(),
},
)
)In [11]:
reviser_chain = (
# Listen for events in the reviser's inbox
reviser_inbox.subscribe()
| {"draft": reviser}
# Publish to the editors inbox
| editor_inbox.publish()
)In [12]:
web_researcher = PubSub(
processes=(draft_chain, editor_chain, reviser_chain),
connection=InMemoryPubSubConnection(),
)In [13]:
web_researcher.invoke({"question": "What food do turtles eat?"})Out [13]:
[{'draft': 'Turtles are a highly diverse group of animals when it comes to their dietary preferences. Their food choices vary depending on the species and their surroundings. Sea turtles, for example, primarily consume sea grass, seaweed, and jellyfish. On the other hand, land turtles, like the well-known Tortuga, prefer leafy greens such as lettuce and kale. Certain turtles even include protein in their diets, enjoying insects, small fish, or even carrion. It is crucial to understand what your turtle likes to eat in order to maintain their well-being and happiness. However, it is always advisable to consult a veterinarian with expertise in turtles before making any changes to their diet.'}]