test malformed response isolation paths

Signed-off-by: kigland <shuaizhicheng336@gmail.com>

Author: koriyoshi2041

tests/nodes/test_llm_analyzer_base.py

@@ -376,6 +376,27 @@ def test_run_batches_uses_message_text_for_content_blocks(self) -> None:
 
         assert results[0][1] == ["chunk"]
 
+    @patch(MOCK_PATCH_TARGET, _mock_get_chat_model)
+    def test_run_batches_isolates_raw_invoke_validation_error(self) -> None:
+        analyzer = _RawTextAnalyzer(base_prompt="test", model=self.MODEL)
+
+        def _invoke(prompt: str) -> AIMessage:
+            if "b.py" in prompt:
+                LLMAnalysisResult.model_validate({"findings": 'We{"findings":[]}'})
+            return AIMessage(content="ok")
+
+        analyzer._llm.invoke.side_effect = _invoke
+        batches = [
+            Batch(file_path="a.py", content="code a"),
+            Batch(file_path="b.py", content="code b"),
+            Batch(file_path="c.py", content="code c"),
+        ]
+
+        results = analyzer.run_batches(batches)
+
+        assert {batch.file_path for batch, _ in results} == {"a.py", "c.py"}
+        assert [items for _, items in results] == [["ok"], ["ok"]]
+
     @patch(MOCK_PATCH_TARGET, _mock_get_chat_model)
     async def test_arun_batches_uses_message_text_for_content_blocks(self) -> None:
         analyzer = _RawTextAnalyzer(base_prompt="test", model=self.MODEL)
@@ -431,6 +452,28 @@ def test_value_error_still_propagates(self) -> None:
         with pytest.raises(ValueError, match="no API key"):
             analyzer.run_batches([Batch(file_path="a.py", content="code")])
 
+    @patch(MOCK_PATCH_TARGET, _mock_get_chat_model)
+    def test_parse_validation_error_does_not_abort_the_others(self) -> None:
+        analyzer = LLMAnalyzerBase(base_prompt="test", model=self.MODEL)
+        analyzer._structured_llm.invoke.return_value = LLMAnalysisResult(findings=[])
+        original_parse = analyzer.parse_response
+
+        def _parse(response: object, batch: Batch) -> list[Finding]:
+            if batch.file_path == "b.py":
+                LLMAnalysisResult.model_validate({"findings": 'We{"findings":[]}'})
+            return original_parse(response, batch)
+
+        analyzer.parse_response = _parse
+        batches = [
+            Batch(file_path="a.py", content="code a"),
+            Batch(file_path="b.py", content="code b"),
+            Batch(file_path="c.py", content="code c"),
+        ]
+
+        results = analyzer.run_batches(batches)
+
+        assert {batch.file_path for batch, _ in results} == {"a.py", "c.py"}
+
 
 # ---------------------------------------------------------------------------
 # LLMAnalyzerBase.arun_batches (async parallel execution)