extract log (#7161)

packages/service/core/workflow/dispatch/ai/extract.ts

@@ -241,12 +241,32 @@ const completions = async (props: ActionProps) => {
   }
 
   try {
+    const arg = json5.parse(jsonStr);
+    if (!arg || typeof arg !== 'object' || Array.isArray(arg)) {
+      logger.warn('Content extract result is not an object', {
+        requestId,
+        model: extractModel.model,
+        finishReason,
+        answerLength: answer.length,
+        jsonLength: jsonStr.length,
+        resultType: Array.isArray(arg) ? 'array' : typeof arg
+      });
+
+      return {
+        rawResponse: answer,
+        inputTokens,
+        outputTokens,
+        usedUserOpenAIKey,
+        arg: {}
+      };
+    }
+
     return {
       rawResponse: answer,
       inputTokens,
       outputTokens,
       usedUserOpenAIKey,
-      arg: json5.parse(jsonStr) as Record<string, any>
+      arg: arg as Record<string, any>
     };
   } catch (error) {
     logger.warn('Failed to parse extract result', {

packages/service/test/core/workflow/dispatch/ai/extract.test.ts

@@ -209,6 +209,25 @@ describe('dispatchContentExtract', () => {
     });
   });
 
+  it('ignores scalar JSON responses and keeps the workflow running', async () => {
+    getLLMModelMock.mockReturnValue({
+      model: 'gpt-4o',
+      name: 'GPT-4o',
+      maxContext: 128000,
+      reasoning: false,
+      toolChoice: false
+    });
+    createLLMResponseMock.mockResolvedValue(mockLLMResponse('1'));
+
+    const result = await dispatchContentExtract(createProps());
+
+    expect(result.data).toMatchObject({
+      success: true,
+      name: ''
+    });
+    expect(result.error).toBeUndefined();
+  });
+
   it('extracts multiple fields and removes fields outside the schema', async () => {
     getLLMModelMock.mockReturnValue({
       model: 'gpt-4o',