andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-04-11 21:42:36 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

fix: guard lazy executor in test utils + convert delegation logging to permanent debug level

Browse Source 
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Alex
2026-04-01 14:35:20 -07:00
parent b8aa645f5d
commit 3277e2149c
2 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/crewai/src/crewai/tools/agent_tools/base_agent_tools.py
View File

@@ -127,18 +127,16 @@ class BaseAgentTool(BaseTool):
logger.debug(
f"Created task for agent '{self.sanitize_agent_name(selected_agent.role)}': {task}"
)
# DEBUG: Verify parent event ID propagation during delegation
parent_id_before = get_current_parent_id()
logger.debug(
f"[DELEGATION SCOPE] Before execute_task - parent_event_id: {parent_id_before}, "
f"delegating to agent: {self.sanitize_agent_name(selected_agent.role)}"
f"Delegation starting: parent_event_id={parent_id_before}, "
f"target_agent={self.sanitize_agent_name(selected_agent.role)}"
)
result = selected_agent.execute_task(task_with_assigned_agent, context)
# DEBUG: Verify scope chain after delegation completes
parent_id_after = get_current_parent_id()
logger.debug(
f"[DELEGATION SCOPE] After execute_task - parent_event_id: {parent_id_after}, "
f"delegation complete for agent: {self.sanitize_agent_name(selected_agent.role)}"
f"Delegation complete: parent_event_id={parent_id_after}, "
f"target_agent={self.sanitize_agent_name(selected_agent.role)}"
)
return result
except Exception as e:

11
lib/crewai/tests/utils.py
View File

@@ -32,8 +32,9 @@ def wait_for_event_handlers(timeout: float = 5.0) -> None:
except Exception: # noqa: S110
pass
crewai_event_bus._sync_executor.shutdown(wait=True)
crewai_event_bus._sync_executor = ThreadPoolExecutor(
max_workers=10,
thread_name_prefix="CrewAISyncHandler",
)
if getattr(crewai_event_bus, '_executor_initialized', False):
crewai_event_bus._sync_executor.shutdown(wait=True)
crewai_event_bus._sync_executor = ThreadPoolExecutor(
max_workers=10,
thread_name_prefix="CrewAISyncHandler",
)