Add openai.finish_reason span attribute for OpenAIChatModel

packages/ai-jsx/package.json

@@ -4,7 +4,7 @@
   "repository": "fixie-ai/ai-jsx",
   "bugs": "https://github.com/fixie-ai/ai-jsx/issues",
   "homepage": "https://ai-jsx.com",
-  "version": "0.28.0",
+  "version": "0.28.1",
   "volta": {
     "extends": "../../package.json"
   },

packages/ai-jsx/src/lib/openai.tsx

@@ -546,6 +546,7 @@ export async function* OpenAIChatModel(
 
     throw ex;
   }
+  let finishReason: string | undefined = undefined;
   const iterator = chatResponse[Symbol.asyncIterator]();
 
   // We have a single response iterator, but we'll wrap tokens _within_ the structure of <AssistantMessage> or <FunctionCall>
@@ -567,6 +568,10 @@ export async function* OpenAIChatModel(
     } while (next.value.choices.length == 0);
 
     logger.trace({ deltaMessage: next.value }, 'Got delta message');
+
+    if (next.value.choices[0].finish_reason) {
+      finishReason = next.value.choices[0].finish_reason;
+    }
     return next.value.choices[0].delta;
   }
 
@@ -667,6 +672,12 @@ export async function* OpenAIChatModel(
     }
   }
 
+  // TS doesn't realize that the advance closure can set `finishReason`.
+  // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
+  if (finishReason) {
+    logger.setAttribute('openai.finish_reason', finishReason);
+  }
+
   // Render the completion conversation to log it.
   await renderToConversation(outputMessages, render, logger, 'completion', tokenCountForConversationMessage);
   return AI.AppendOnlyStream;

packages/docs/docs/changelog.md

@@ -1,6 +1,10 @@
 # Changelog
 
-## 0.28.0
+## 0.28.1
+
+- Add `openai.finish_reason` span attribute for `OpenAIChatModel`
+
+## [0.28.0](https://github.com/fixie-ai/ai-jsx/commit/73251358a1121c98e9059c57d3c905b6156447c4)
 
 - Improved completion/prompt logging to include explicit message text
 

packages/examples/test/core/completion.tsx

@@ -119,6 +119,7 @@ describe('OpenTelemetry', () => {
           {"hello"}
         </UserMessage>
       </OpenAIChatModel>",
+          "openai.finish_reason": "stop",
         },
         {
           "ai.jsx.result": "opentel response from OpenAI",
@@ -257,6 +258,7 @@ describe('OpenTelemetry', () => {
           {"hello"}
         </UserMessage>
       </OpenAIChatModel>",
+          "openai.finish_reason": "stop",
         },
         {
           "ai.jsx.result": "opentel response from OpenAI",

packages/examples/test/lib/openai.tsx

@@ -21,7 +21,7 @@ describe('OpenAIChatModel', () => {
                   }),
                 ]);
 
-                yield { choices: [{ delta: { role: 'assistant', content: 'Hi!' } }] };
+                yield { choices: [{ delta: { role: 'assistant', content: 'Hi!' }, finish_reason: 'stop' }] };
               },
             },
           },