@@ -194,7 +194,7 @@ def _add_structure_sync():
194
194
current_turn += 1
195
195
self ._current_user_turn = current_turn
196
196
197
- msg_type = self ._classify_simple (item )
197
+ msg_type = self ._classify_message_type (item )
198
198
tool_name = self ._extract_tool_name (item )
199
199
200
200
structure_data .append (
@@ -228,7 +228,7 @@ def _add_structure_sync():
228
228
)
229
229
# Don't re-raise - structure metadata is supplementary
230
230
231
- def _classify_simple (self , item : TResponseInputItem ) -> str :
231
+ def _classify_message_type (self , item : TResponseInputItem ) -> str :
232
232
"""Simple classification."""
233
233
if isinstance (item , dict ):
234
234
if item .get ("role" ) == "user" :
@@ -328,10 +328,10 @@ def _get_active_items_sync():
328
328
329
329
return await asyncio .to_thread (_get_active_items_sync )
330
330
331
- async def soft_delete_from_turn (self , user_turn_number : int ) -> bool :
331
+ async def deactivate_from_turn (self , user_turn_number : int ) -> bool :
332
332
"""Soft delete conversation from a specific user turn onwards."""
333
333
334
- def _soft_delete_sync ():
334
+ def _deactivate_sync ():
335
335
conn = self ._get_connection ()
336
336
with self ._lock if self ._is_memory_db else threading .Lock ():
337
337
with closing (conn .cursor ()) as cursor :
@@ -347,7 +347,7 @@ def _soft_delete_sync():
347
347
conn .commit ()
348
348
return affected > 0
349
349
350
- return await asyncio .to_thread (_soft_delete_sync )
350
+ return await asyncio .to_thread (_deactivate_sync )
351
351
352
352
async def reactivate_from_turn (self , user_turn_number : int ) -> bool :
353
353
"""Reactivate soft-deleted conversation from a specific turn."""
0 commit comments