From d0e26f37e5749f4a2c46320bbb69bdcae744f6c5 Mon Sep 17 00:00:00 2001
From: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
Date: Thu, 18 Sep 2025 20:38:33 +0000
Subject: [PATCH] fix: Replace assert with conditional check for event bus
 emission
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- Replace assert hasattr(crewai_event_bus, 'emit') with proper conditional
- Fixes S101 lint error in modified code section
- Maintains same functionality with better error handling

Co-Authored-By: João <joao@crewai.com>
---
 src/crewai/llm.py | 42 +++++++++++++++++++++---------------------
 1 file changed, 21 insertions(+), 21 deletions(-)

diff --git a/src/crewai/llm.py b/src/crewai/llm.py
index 0dbbfeeeb..9210228d0 100644
--- a/src/crewai/llm.py
+++ b/src/crewai/llm.py
@@ -782,27 +782,27 @@ class LLM(BaseLLM):
                 current_tool_accumulator.function.arguments += (
                     tool_call.function.arguments
                 )
-            assert hasattr(crewai_event_bus, "emit")
-            # Convert ChatCompletionDeltaToolCall to ToolCall format
-            from crewai.events.types.llm_events import ToolCall, FunctionCall
-            converted_tool_call = ToolCall(
-                id=tool_call.id,
-                function=FunctionCall(
-                    name=tool_call.function.name,
-                    arguments=tool_call.function.arguments or ""
-                ),
-                type=tool_call.type,
-                index=tool_call.index
-            )
-            crewai_event_bus.emit(
-                self,
-                event=LLMStreamChunkEvent(
-                    tool_call=converted_tool_call,
-                    chunk=tool_call.function.arguments,
-                    from_task=from_task,
-                    from_agent=from_agent,
-                ),
-            )
+            if hasattr(crewai_event_bus, "emit"):
+                # Convert ChatCompletionDeltaToolCall to ToolCall format
+                from crewai.events.types.llm_events import ToolCall, FunctionCall
+                converted_tool_call = ToolCall(
+                    id=tool_call.id,
+                    function=FunctionCall(
+                        name=tool_call.function.name,
+                        arguments=tool_call.function.arguments or ""
+                    ),
+                    type=tool_call.type,
+                    index=tool_call.index
+                )
+                crewai_event_bus.emit(
+                    self,
+                    event=LLMStreamChunkEvent(
+                        tool_call=converted_tool_call,
+                        chunk=tool_call.function.arguments,
+                        from_task=from_task,
+                        from_agent=from_agent,
+                    ),
+                )
 
             if (
                 current_tool_accumulator.function.name