2424from typing import Any
2525
2626from shell_utils import shell_tool_call
27- from mcp_utils import DEFAULT_MCP_CLIENT_SESSION_TIMEOUT , ReconnectingMCPServerStdio , AsyncDebugMCPServerStdio , MCPNamespaceWrap , mcp_client_params , mcp_system_prompt , StreamableMCPThread
27+ from mcp_utils import DEFAULT_MCP_CLIENT_SESSION_TIMEOUT , ReconnectingMCPServerStdio , AsyncDebugMCPServerStdio , MCPNamespaceWrap , mcp_client_params , mcp_system_prompt , StreamableMCPThread , compress_name
2828from render_utils import render_model_output , flush_async_output
2929from env_utils import TmpEnv
3030from yaml_parser import YamlParser
@@ -256,7 +256,7 @@ async def mcp_session_task(
256256 for handoff_agent in list (agents .keys ())[1 :]:
257257 handoffs .append (TaskAgent (
258258 # XXX: name has to be descriptive for an effective handoff
259- name = handoff_agent ,
259+ name = compress_name ( handoff_agent ) ,
260260 instructions = prompt_with_handoff_instructions (
261261 mcp_system_prompt (
262262 agents [handoff_agent ]['personality' ],
@@ -400,7 +400,7 @@ async def on_handoff_hook(
400400 if p :
401401 personality = available_tools .personalities .get (p )
402402 if personality is None :
403- raise ValueError ("No such personality! " )
403+ raise ValueError (f "No such personality: { p } " )
404404
405405 await deploy_task_agents (
406406 available_tools ,
@@ -414,7 +414,7 @@ async def on_handoff_hook(
414414
415415 taskflow = available_tools .taskflows .get (t )
416416 if taskflow is None :
417- raise ValueError ("No such taskflow! " )
417+ raise ValueError (f "No such taskflow: { t } " )
418418
419419 await render_model_output (f"** 🤖💪 Running Task Flow: { t } \n " )
420420
0 commit comments