mirror of
https://github.com/crewAIInc/crewAI.git
synced 2026-01-09 16:18:30 +00:00
Sanitize agent roles to ensure valid directory names (#1037)
This commit is contained in:
@@ -47,7 +47,7 @@ class RAGStorage(Storage):
|
|||||||
os.environ["OPENAI_API_KEY"] = "fake"
|
os.environ["OPENAI_API_KEY"] = "fake"
|
||||||
|
|
||||||
agents = crew.agents if crew else []
|
agents = crew.agents if crew else []
|
||||||
agents = [agent.role for agent in agents]
|
agents = [self._sanitize_role(agent.role) for agent in agents]
|
||||||
agents = "_".join(agents)
|
agents = "_".join(agents)
|
||||||
|
|
||||||
config = {
|
config = {
|
||||||
@@ -77,6 +77,12 @@ class RAGStorage(Storage):
|
|||||||
self.app.llm = FakeLLM()
|
self.app.llm = FakeLLM()
|
||||||
if allow_reset:
|
if allow_reset:
|
||||||
self.app.reset()
|
self.app.reset()
|
||||||
|
|
||||||
|
def _sanitize_role(self, role: str) -> str:
|
||||||
|
"""
|
||||||
|
Sanitizes agent roles to ensure valid directory names.
|
||||||
|
"""
|
||||||
|
return role.replace('\n', '').replace(' ', '_').replace('/', '_')
|
||||||
|
|
||||||
def save(self, value: Any, metadata: Dict[str, Any]) -> None:
|
def save(self, value: Any, metadata: Dict[str, Any]) -> None:
|
||||||
self._generate_embedding(value, metadata)
|
self._generate_embedding(value, metadata)
|
||||||
|
|||||||
Reference in New Issue
Block a user