Fixed JSON formatting

src/crewai/events/utils/console_formatter.py

@@ -24,6 +24,7 @@ class ConsoleFormatter:
     def __init__(self, verbose: bool = False):
         self.console = Console(width=None)
         self.verbose = verbose
+        self.tool_usage_counts: dict[str, int] = {}
         # Live instance to dynamically update a Tree renderable (e.g. the Crew tree)
         # When multiple Tree objects are printed sequentially we reuse this Live
         # instance so the previous render is replaced instead of writing a new one.
@@ -693,7 +694,8 @@ def handle_llm_call_completed(
         if tool_branch is not None and "Thinking" in str(tool_branch.label):
             thinking_branch_to_remove = tool_branch
 
-        # Method 2: Fallback - search for any thinking node if tool_branch is None or not thinking
+        # Method 2: Fallback - search for any thinking node if tool_branch is None
+        # or not thinking
         if thinking_branch_to_remove is None:
             parents = [
                 self.current_lite_agent_branch,
@@ -752,7 +754,8 @@ def handle_llm_call_failed(
         if tool_branch is not None and "Thinking" in str(tool_branch.label):
             thinking_branch_to_update = tool_branch
 
-        # Method 2: Fallback - search for any thinking node if tool_branch is None or not thinking
+        # Method 2: Fallback - search for any thinking node if tool_branch is None or
+        # not thinking
         if thinking_branch_to_update is None:
             parents = [
                 self.current_lite_agent_branch,
@@ -1377,7 +1380,7 @@ def handle_agent_logs_execution(
         if isinstance(formatted_answer, AgentAction):
             thought = re.sub(r"\n+", "\n", formatted_answer.thought)
             formatted_json = json.dumps(
-                formatted_answer.tool_input,
+                json.loads(formatted_answer.tool_input),
                 indent=2,
                 ensure_ascii=False,
             )
@@ -1592,10 +1595,14 @@ def handle_memory_query_completed(
                     if "Sources Used" in str(inner_child.label):
                         sources_branch.add(f"✅ {memory_type} ({query_time_ms:.2f}ms)")
                         break
-                else:
-                    sources_branch = child.add("Sources Used")
-                    sources_branch.add(f"✅ {memory_type} ({query_time_ms:.2f}ms)")
-                    break
+
+                # If not found, create it under this child
+                if sources_branch is None:
+                    sources_branch = child.add("🧠 Sources Used")
+
+                sources_branch.add(f"✅ {memory_type} ({query_time_ms:.2f}ms)")
+                break
+
 
     def handle_memory_query_failed(
         self,
@@ -1625,10 +1632,14 @@ def handle_memory_query_failed(
                     if "Sources Used" in str(inner_child.label):
                         sources_branch.add(f"❌ {memory_type} - Error: {error}")
                         break
-                else:
+
+                # If not found, create it under this child
+                if sources_branch is None:
                     sources_branch = child.add("🧠 Sources Used")
-                    sources_branch.add(f"❌ {memory_type} - Error: {error}")
-                    break
+
+                sources_branch.add(f"❌ {memory_type} - Error: {error}")
+                break
+
 
     def handle_memory_save_started(
         self, agent_branch: Tree | None, crew_tree: Tree | None

src/crewai/tools/structured_tool.py

@@ -270,7 +270,7 @@ def invoke(
 
         if inspect.iscoroutinefunction(self.func):
             return asyncio.run(self.func(**parsed_args, **kwargs))
-
+        
         result = self.func(**parsed_args, **kwargs)
 
         if asyncio.iscoroutine(result):