* Clear checkpoint for the given thread_id
(checkpointer: SqliteSaver, threadId: string)
| 23 | * Clear checkpoint for the given thread_id |
| 24 | */ |
| 25 | async function clearCheckpoint(checkpointer: SqliteSaver, threadId: string): Promise<void> { |
| 26 | try { |
| 27 | // Delete all checkpoints for this thread_id |
| 28 | await checkpointer.deleteThread(threadId); |
| 29 | } catch (error) { |
| 30 | const errorMessage = error instanceof Error ? error.message : String(error); |
| 31 | logger.printWarnLog(`Failed to clear checkpoint: ${errorMessage}`); |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | /** |
| 36 | * Check and prompt user for checkpoint decision |
no outgoing calls
no test coverage detected