@@ -421,7 +421,7 @@ async def process(self, item: InterruptibleAgentResponseEvent[AgentResponse]):
421
421
if self .last_agent_response_tracker is not None :
422
422
await self .last_agent_response_tracker .wait ()
423
423
item .agent_response_tracker .set ()
424
- await self .conversation .mark_terminated (bot_disconnect = True )
424
+ self .conversation .mark_terminated (bot_disconnect = True )
425
425
return
426
426
427
427
agent_response_message = typing .cast (AgentResponseMessage , agent_response )
@@ -747,7 +747,7 @@ async def send_initial_message(
747
747
748
748
async def action_on_idle (self ):
749
749
logger .debug ("Conversation idle for too long, terminating" )
750
- await self .mark_terminated (bot_disconnect = True )
750
+ self .mark_terminated (bot_disconnect = True )
751
751
return
752
752
753
753
async def check_for_idle (self ):
@@ -961,11 +961,11 @@ async def get_chunks(
961
961
synthesis_result .synthesis_total_span .finish ()
962
962
return message_sent , cut_off
963
963
964
- async def mark_terminated (self , bot_disconnect : bool = False ):
964
+ def mark_terminated (self , bot_disconnect : bool = False ):
965
965
self .active = False
966
966
967
967
async def terminate (self ):
968
- await self .mark_terminated ()
968
+ self .mark_terminated ()
969
969
self .broadcast_interrupt ()
970
970
self .events_manager .publish_event (
971
971
TranscriptCompleteEvent (
0 commit comments