andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-09-20 18:13:49 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

docs: pass validated structured notes in isolation example

Browse Source 
Use response_format and result.pydantic so the Flow handoff is OutreachNotes, not a raw string dump.

Co-authored-by: Rip&Tear <theCyberTech@users.noreply.github.com>
This commit is contained in:
Cursor Agent
2026-08-24 10:28:27 +00:00
parent d3e3a2c591
commit 102bd51541
4 changed files with 68 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
docs/edge/ar/guides/agents/secure-agent-design.mdx
View File

@@ -293,24 +293,36 @@ analyst = Agent(
from crewai.flow.flow import Flow, listen, start
from pydantic import BaseModel
class OutreachNotes(BaseModel):
claims: list[str]
sources: list[str]
class PipelineState(BaseModel):
topic: str = ""
notes: list[str] = []
notes: OutreachNotes | None = None
email_status: str = ""
class SecureOutreachFlow(Flow[PipelineState]):
@start()
def research(self):
result = researcher.kickoff(
f"Extract factual notes about {self.state.topic}."
f"Extract factual notes about {self.state.topic}.",
response_format=OutreachNotes,
)
self.state.notes = [result.raw]
notes = result.pydantic
if not isinstance(notes, OutreachNotes) or not notes.claims or not notes.sources:
raise ValueError("Research must return validated OutreachNotes.")
self.state.notes = notes
@listen(research)
def send(self):
approved = "\n".join(self.state.notes)
notes = self.state.notes
if notes is None:
raise ValueError("No validated notes to send.")
result = sender.kickoff(
f"Send outreach using only these notes:\n{approved}"
"Send outreach using only these claims and sources:\n"
f"claims={notes.claims}\n"
f"sources={notes.sources}"
)
self.state.email_status = result.raw
```

22
docs/edge/en/guides/agents/secure-agent-design.mdx
View File

@@ -293,24 +293,36 @@ analyst = Agent(
from crewai.flow.flow import Flow, listen, start
from pydantic import BaseModel
class OutreachNotes(BaseModel):
claims: list[str]
sources: list[str]
class PipelineState(BaseModel):
topic: str = ""
notes: list[str] = []
notes: OutreachNotes | None = None
email_status: str = ""
class SecureOutreachFlow(Flow[PipelineState]):
@start()
def research(self):
result = researcher.kickoff(
f"Extract factual notes about {self.state.topic}."
f"Extract factual notes about {self.state.topic}.",
response_format=OutreachNotes,
)
self.state.notes = [result.raw]
notes = result.pydantic
if not isinstance(notes, OutreachNotes) or not notes.claims or not notes.sources:
raise ValueError("Research must return validated OutreachNotes.")
self.state.notes = notes
@listen(research)
def send(self):
approved = "\n".join(self.state.notes)
notes = self.state.notes
if notes is None:
raise ValueError("No validated notes to send.")
result = sender.kickoff(
f"Send outreach using only these notes:\n{approved}"
"Send outreach using only these claims and sources:\n"
f"claims={notes.claims}\n"
f"sources={notes.sources}"
)
self.state.email_status = result.raw
```

22
docs/edge/ko/guides/agents/secure-agent-design.mdx
View File

@@ -293,24 +293,36 @@ analyst = Agent(
from crewai.flow.flow import Flow, listen, start
from pydantic import BaseModel
class OutreachNotes(BaseModel):
claims: list[str]
sources: list[str]
class PipelineState(BaseModel):
topic: str = ""
notes: list[str] = []
notes: OutreachNotes | None = None
email_status: str = ""
class SecureOutreachFlow(Flow[PipelineState]):
@start()
def research(self):
result = researcher.kickoff(
f"Extract factual notes about {self.state.topic}."
f"Extract factual notes about {self.state.topic}.",
response_format=OutreachNotes,
)
self.state.notes = [result.raw]
notes = result.pydantic
if not isinstance(notes, OutreachNotes) or not notes.claims or not notes.sources:
raise ValueError("Research must return validated OutreachNotes.")
self.state.notes = notes
@listen(research)
def send(self):
approved = "\n".join(self.state.notes)
notes = self.state.notes
if notes is None:
raise ValueError("No validated notes to send.")
result = sender.kickoff(
f"Send outreach using only these notes:\n{approved}"
"Send outreach using only these claims and sources:\n"
f"claims={notes.claims}\n"
f"sources={notes.sources}"
)
self.state.email_status = result.raw
```

22
docs/edge/pt-BR/guides/agents/secure-agent-design.mdx
View File

@@ -293,24 +293,36 @@ analyst = Agent(
from crewai.flow.flow import Flow, listen, start
from pydantic import BaseModel
class OutreachNotes(BaseModel):
claims: list[str]
sources: list[str]
class PipelineState(BaseModel):
topic: str = ""
notes: list[str] = []
notes: OutreachNotes | None = None
email_status: str = ""
class SecureOutreachFlow(Flow[PipelineState]):
@start()
def research(self):
result = researcher.kickoff(
f"Extract factual notes about {self.state.topic}."
f"Extract factual notes about {self.state.topic}.",
response_format=OutreachNotes,
)
self.state.notes = [result.raw]
notes = result.pydantic
if not isinstance(notes, OutreachNotes) or not notes.claims or not notes.sources:
raise ValueError("Research must return validated OutreachNotes.")
self.state.notes = notes
@listen(research)
def send(self):
approved = "\n".join(self.state.notes)
notes = self.state.notes
if notes is None:
raise ValueError("No validated notes to send.")
result = sender.kickoff(
f"Send outreach using only these notes:\n{approved}"
"Send outreach using only these claims and sources:\n"
f"claims={notes.claims}\n"
f"sources={notes.sources}"
)
self.state.email_status = result.raw
```