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

fix: Replace assert with conditional check for event bus emission

Browse Source 
- 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>
This commit is contained in:
Devin AI
2025-09-18 20:38:33 +00:00
parent af6c61bcb8
commit d0e26f37e5
1 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/crewai/llm.py
View File

@@ -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