farcasclaudiu/Flowise
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/Flowise.git synced 2026-06-29 01:01:11 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1447 from FlowiseAI/feature/OpenAI-Assistant

Browse Source 
Feature/OpenAI Assistant
This commit is contained in:
Henry Heng
2023-12-29 14:54:31 +00:00
committed by GitHub
parent 630d40f867 8eabd8f0c2
commit b0fa2e2174
1 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/components/nodes/agents/OpenAIAssistant/OpenAIAssistant.ts
+6 -1
View File
@@ -324,7 +324,8 @@ class OpenAIAssistant_Agents implements INode {
const newRun = await openai.beta.threads.runs.retrieve(threadId, runId) const newRun = await openai.beta.threads.runs.retrieve(threadId, runId)
const newStatus = newRun?.status const newStatus = newRun?.status
if (submitToolOutputs.length && newStatus !== 'in_progress') { try {
if (submitToolOutputs.length && newStatus === 'requires_action') {
await openai.beta.threads.runs.submitToolOutputs(threadId, runId, { await openai.beta.threads.runs.submitToolOutputs(threadId, runId, {
tool_outputs: submitToolOutputs tool_outputs: submitToolOutputs
}) })
@@ -333,6 +334,10 @@ class OpenAIAssistant_Agents implements INode {
await openai.beta.threads.runs.cancel(threadId, runId) await openai.beta.threads.runs.cancel(threadId, runId)
resolve('requires_action_retry') resolve('requires_action_retry')
} }
} catch (e) {
clearInterval(timeout)
reject(new Error(`Error submitting tool outputs: ${state}, Thread ID: ${threadId}, Run ID: ${runId}`))
}
} }
} else if (state === 'cancelled' || state === 'expired' || state === 'failed') { } else if (state === 'cancelled' || state === 'expired' || state === 'failed') {
clearInterval(timeout) clearInterval(timeout)