Preparing new version

This commit is contained in:
João Moura
2024-03-11 17:36:58 -03:00
parent cb5a528550
commit 35f8919e73
7 changed files with 238 additions and 239 deletions

View File

@@ -7,9 +7,8 @@ from langchain.agents.tools import tool as LangChainTool
from langchain.memory import ConversationSummaryMemory
from langchain.tools.render import render_text_description
from langchain_core.agents import AgentAction
from langchain_openai import ChatOpenAI
from langchain_core.callbacks import BaseCallbackHandler
from langchain_openai import ChatOpenAI
from pydantic import (
UUID4,
BaseModel,
@@ -251,7 +250,7 @@ class Agent(BaseModel):
"step_callback": self.step_callback,
"tools_handler": self.tools_handler,
"function_calling_llm": self.function_calling_llm,
"callbacks": self.callbacks
"callbacks": self.callbacks,
}
if self._rpm_controller:

View File

@@ -35,7 +35,7 @@ class {{crew_name}}Crew():
)
@task
def research_task(self) -> Task:
def reporting_task(self) -> Task:
return Task(
config=self.tasks_config['reporting_task'],
agent=self.reporting_analyst(),

View File

@@ -6,7 +6,7 @@ authors = ["Your Name <you@example.com>"]
[tool.poetry.dependencies]
python = ">=3.10,<=3.13"
crewai = {extras = ["tools"], version = "^0.20.0"}
crewai = {extras = ["tools"], version = "^0.22.0"}
[tool.poetry.scripts]
{{folder_name}} = "{{folder_name}}.main:run"

View File

@@ -232,9 +232,9 @@ class Crew(BaseModel):
task.tools += AgentTools(agents=agents_for_delegation).tools()
role = task.agent.role if task.agent is not None else "None"
self._logger.log("debug", f" == Working Agent: {role}", color="bold_yellow")
self._logger.log("debug", f"== Working Agent: {role}", color="bold_yellow")
self._logger.log(
"info", f" == Starting Task: {task.description}", color="bold_yellow"
"info", f"== Starting Task: {task.description}", color="bold_yellow"
)
output = task.execute(context=task_output)
@@ -242,7 +242,7 @@ class Crew(BaseModel):
task_output = output
role = task.agent.role if task.agent is not None else "None"
self._logger.log("debug", f"[{role}] Task output: {task_output}\n\n")
self._logger.log("debug", f"== [{role}] Task output: {task_output}\n\n")
self._finish_execution(task_output)
return self._format_output(task_output)