diff --git a/packages/orchestration-service/src/chat/index.js b/packages/orchestration-service/src/chat/index.js index d28854d..e01d339 100644 --- a/packages/orchestration-service/src/chat/index.js +++ b/packages/orchestration-service/src/chat/index.js @@ -125,6 +125,7 @@ async function chat(externalId, userMessage, options = {}) { } async function chatStream(externalId, userMessage, onChunk, options = {}) { + console.log('[orchestration] chatStream called:', { externalId, userMessage: userMessage.slice(0, 50) }); let session = await memory.getSessionByExternalId(externalId); if (!session) session = await memory.createSession(externalId); @@ -175,6 +176,7 @@ async function chatStream(externalId, userMessage, onChunk, options = {}) { } } catch (err) { console.error('[orchestration] Failed to parse inference SSE event:', raw, err.message); + throw err; // add this temporarily } } }