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

Fix/logger - fix #1412 (#1413)

Browse Source 
* improved logger

* log file looks better

* better lines written to log file

---------

Co-authored-by: João Moura <joaomdmoura@gmail.com>
This commit is contained in:
Shahar Yair
2024-10-11 01:15:34 +03:00
committed by GitHub
parent 063ad2d99d
commit d5427fb019
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/crewai/crew.py
View File

@@ -771,7 +771,7 @@ class Crew(BaseModel):
def _log_task_start(self, task: Task, role: str = "None"):
if self.output_log_file:
self._file_handler.log(agent=role, task=task.description, status="started")
self._file_handler.log(task_name=task.name, task=task.description, agent=role, status="started")
def _update_manager_tools(self, task: Task):
if self.manager_agent:
@@ -793,7 +793,7 @@ class Crew(BaseModel):
def _process_task_result(self, task: Task, output: TaskOutput) -> None:
role = task.agent.role if task.agent is not None else "None"
if self.output_log_file:
self._file_handler.log(agent=role, task=output, status="completed")
self._file_handler.log(task_name=task.name, task=task.description, agent=role, status="completed", output=output.raw)
def _create_crew_output(self, task_outputs: List[TaskOutput]) -> CrewOutput:
if len(task_outputs) != 1:

2
src/crewai/utilities/file_handler.py
View File

@@ -16,7 +16,7 @@ class FileHandler:
def log(self, **kwargs):
now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
message = f"{now}: ".join([f"{key}={value}" for key, value in kwargs.items()])
message = f"{now}: " + ", ".join([f"{key}=\"{value}\"" for key, value in kwargs.items()]) + "\n"
with open(self._path, "a", encoding="utf-8") as file:
file.write(message + "\n")