@@ -120,9 +120,9 @@ def __init__(
120120 self ._client : Any | None = None
121121 self ._connected_event = asyncio .Event ()
122122
123- # Tool confirmation state for HITL round-trip
124- self ._interrupt_end_event = asyncio .Event ()
125- self ._confirm_tool_call_value : dict [str , Any ] | None = None
123+ # Tool confirmation HITL round-trip
124+ self ._tool_confirmation_event = asyncio .Event ()
125+ self ._tool_confirmation_value : dict [str , Any ] | None = None
126126 self ._current_message_id : str | None = None
127127
128128 # Set CAS_WEBSOCKET_DISABLED when using the debugger to prevent websocket errors from
@@ -362,12 +362,12 @@ async def wait_for_resume(self) -> dict[str, Any]:
362362 Returns:
363363 Resume data from the tool call confirmation event: {approved, input}
364364 """
365- self ._interrupt_end_event .clear ()
366- self ._confirm_tool_call_value = None
365+ self ._tool_confirmation_event .clear ()
366+ self ._tool_confirmation_value = None
367367
368- await self ._interrupt_end_event .wait ()
368+ await self ._tool_confirmation_event .wait ()
369369
370- return self ._confirm_tool_call_value or {}
370+ return self ._tool_confirmation_value or {}
371371
372372 @property
373373 def is_connected (self ) -> bool :
@@ -404,11 +404,11 @@ async def _handle_conversation_event(
404404 logger .info (
405405 f"Received confirmToolCall for tool_call_id: { message .tool_call .tool_call_id } , approved: { confirm .approved } "
406406 )
407- self ._confirm_tool_call_value = {
407+ self ._tool_confirmation_value = {
408408 "approved" : confirm .approved ,
409409 "input" : confirm .input ,
410410 }
411- self ._interrupt_end_event .set ()
411+ self ._tool_confirmation_event .set ()
412412 except Exception as e :
413413 logger .warning (f"Error parsing conversation event: { e } " )
414414
0 commit comments