diff --git a/lib/crewai/src/crewai/tools/agent_tools/base_agent_tools.py b/lib/crewai/src/crewai/tools/agent_tools/base_agent_tools.py index 40fdb0f1a..cd3d0d8da 100644 --- a/lib/crewai/src/crewai/tools/agent_tools/base_agent_tools.py +++ b/lib/crewai/src/crewai/tools/agent_tools/base_agent_tools.py @@ -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: diff --git a/lib/crewai/tests/utils.py b/lib/crewai/tests/utils.py index a514634ae..48d1abba8 100644 --- a/lib/crewai/tests/utils.py +++ b/lib/crewai/tests/utils.py @@ -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", + )