diff --git a/backend/src/apis/openai/OpenaiClient.ts b/backend/src/apis/openai/OpenaiClient.ts index 3a58f103e..80a921871 100644 --- a/backend/src/apis/openai/OpenaiClient.ts +++ b/backend/src/apis/openai/OpenaiClient.ts @@ -103,13 +103,15 @@ export class OpenaiClient { } public async deleteThread(threadId: string): Promise { - const result = await this.openai.beta.threads.del(threadId) + const [, result] = await Promise.all([ + OpenaiThreads.delete({ id: threadId }), + this.openai.beta.threads.del(threadId), + ]) if (result.deleted) { - await OpenaiThreads.delete({ id: threadId }) logger.info(`Deleted thread: ${threadId}`) return true } else { - logger.warn(`Failed to delete thread: ${threadId}`) + logger.warn(`Failed to delete thread: ${threadId}, remove from db anyway`) return false } }