落ちた回に、頼んだ相手と相手が言ったことを残す

読めない答えが返ったとき、控えには「ValueError: JSON オブジェクトが見つかりません」
としか出ず、相手の欄は既定の名前のままだった。控えを見た人は「claude が壊れた答えを
返した」と読むが、実際に返したのは別の相手で、理由を知るには AI の履歴まで掘る
必要があった。

本番でそうなった。相手の agent が背景タスクを 2 本抱えたまま親が先に手を離し、
「待っています」という状況説明を返して終わっていた（出力 4,499 トークンのうち
本文は 119 バイト）。

落ちた道でも、実際に頼んだ相手で控えを書き換える。読めない答えの先頭も添える
（全文は AI の履歴にあるので、ここに要るのは一目で分かるぶんだけ）。

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

Author: claude

CLAUDE.md

@@ -455,6 +455,12 @@ GeoNames 全世界地名辞典 = `geonames`(いずれも 348 言語版・195 か
         読めなければ既定の待ち時間 —— 短くしすぎると、明ける前に頼み直して 1 回ぶん
         損をする。**枠と関係ない失敗では締め出さない**(つながらないだけの回もある)。
         断られた区画は**飛ばさず、同じ区画を次の段が引き受ける**
+      - **落ちた回にも、頼んだ相手と相手が言ったことを残す。** 既定の名前のままだと
+        「claude が壊れた答えを返した」と読まれる(実際に返したのは別の相手だった)。
+        読めない答えの**先頭も控えに添える**(`collect._said`)—— 「JSON オブジェクトが
+        見つかりません」だけだと、控えを見た人は AI の履歴まで掘らないと理由が
+        分からない。本番でそうなった(相手の agent が背景タスクを抱えたまま
+        「待っています」と答えて終わり、JSON を返さなかった)
       - **控えに残すのは、決めた相手ではなく頼んだ相手**(`main._who_ran`)。
         ワーカーを使う巡回は自分の欄に相手を書いていないので、書き換えないと
         **履歴の相手の欄が既定の名前で埋まる**(実際にそうなっていた)。

app/collect.py

@@ -276,6 +276,10 @@
 # 読むのは「何が動いたか」の手がかりであって、全件の一覧ではない
 MAX_TITLE_SAMPLE = 20
 
+# 読めなかった答えを、控えに添える長さ。**全文は AI の履歴にある** ——
+# ここに要るのは「何が返ってきたか」が一目で分かるぶんだけ
+MAX_SAID_CHARS = 120
+
 # タグの確かめ方をいくつまで書けるか。**指定であって分類ではない**ので、少なくてよい
 MAX_VERIFY_TAGS = 8
 # 実在を確かめる問い合わせ 1 回ぶんの見出しの数(SQLite の上限に余裕を持たせる)
@@ -1651,6 +1655,12 @@ def _raw_url(raw: dict) -> str:
     return ""
 
 
+def _said(text: str) -> str:
+    """相手が言ったことの先頭。**空なら「何も返さなかった」と書く**(空文字は読めない)。"""
+    head = " ".join((text or "").split())[:MAX_SAID_CHARS]
+    return head or "(何も返ってきませんでした)"
+
+
 def _incoming_urls(collected) -> set[str]:
     """その回に入ってくるぶんの URL の鍵。
 
@@ -1915,7 +1925,11 @@ def parse_response(content: str) -> tuple[list[dict], str | None, str]:
     start = stripped.find("{")
     end = stripped.rfind("}")
     if start < 0:
-        raise ValueError("JSON オブジェクトが見つかりません")
+        # **何が返ってきたかを添える。** 「見つかりません」だけだと、控えを見た人は
+        # AI の履歴まで掘らないと理由が分からない —— 実際にそうなった(相手の agent が
+        # 背景タスクを抱えたまま「待っています」と答えて終わり、JSON を返さなかった)。
+        # **先頭だけ**にするのは、控えに答えを丸ごと写す場所ではないから
+        raise ValueError(f"JSON オブジェクトが見つかりません: {_said(stripped)}")
     try:
         payload = json.loads(stripped[start : end + 1]) if end > start else None
     except ValueError:

app/main.py

@@ -853,6 +853,9 @@ async def _collect_material(name: str, sources: dict) -> str:
     except Exception as e:
         if hasattr(items := locals().get("items"), "close"):
             items.close()
+        # **落ちた回にも、頼んだ相手を残す。** 既定の名前のままだと、控えを見た人は
+        # 「claude が壊れた答えを返した」と読む —— 実際に返したのは別の相手だった
+        who.update(_who_ran(used) or {})
         reason = f"{type(e).__name__}: {e}"
         log.warning("collect %s failed: %s", name, reason)
         await asyncio.to_thread(

tests/test_collect.py

@@ -1745,6 +1745,37 @@ def test_a_once_sweep_runs_only_once(self, sample):
         assert collect.require_runnable(collect.get("news"), "名簿").name == "名簿"
 
 
+class TestWhenTheAnswerIsNotJson:
+    """**何が返ってきたかを控えに添える。**
+
+    「JSON オブジェクトが見つかりません」だけだと、控えを見た人は AI の履歴まで
+    掘らないと理由が分からない —— 本番でそうなった(相手の agent が背景タスクを
+    抱えたまま「待っています」と答えて終わり、JSON を返さなかった)。
+    """
+
+    def test_the_reason_carries_what_came_back(self):
+        with pytest.raises(ValueError) as got:
+            collect.parse_response(
+                "The background task to retrieve painter information is currently running."
+            )
+
+        assert "background task" in str(got.value)
+
+    def test_a_long_answer_is_cut(self):
+        with pytest.raises(ValueError) as got:
+            collect.parse_response("あ" * 500)
+
+        # **全文は AI の履歴にある**。控えに要るのは一目で分かるぶんだけ
+        assert len(str(got.value)) < 200
+
+    def test_an_empty_answer_says_so(self):
+        """空文字は読めない —— 「何も返さなかった」と書く。"""
+        with pytest.raises(ValueError) as got:
+            collect.parse_response("   ")
+
+        assert "何も返ってきませんでした" in str(got.value)
+
+
 class TestStartingTheLapOver:
     """一周をやり直す(`collect.restart_cycle`)。
 

tests/test_workers.py

@@ -720,6 +720,34 @@ def test_a_relayed_run_names_both(self):
         assert out["backend"] == "antigravity → codex"
         assert out["model"] == "gemini → gpt-5.5"
 
+    def test_a_failed_run_still_names_who_answered(self, enabled, monkeypatch):
+        """**落ちた回にも頼んだ相手を残す。** 既定の名前のままだと、控えを見た人は
+        「claude が壊れた答えを返した」と読む —— 実際に返したのは別の相手だった。
+        """
+        import fastapi
+
+        from app import collect, main
+
+        monkeypatch.setenv("CHIEZO_NOTES_DIR", str(enabled / "corpus"))
+        workers.save([workers.Worker("精査", (workers.Step("antigravity", "gemini"),))])
+        _quota("antigravity", 10.0)
+
+        async def garbage(_asked, _messages):
+            return "背景の仕事を待っています"
+
+        monkeypatch.setattr(main, "_ask_for_collection", garbage)
+        collect.create("news", prompt="p", interval_minutes=60,
+                       sweeps=[{"name": "ざっと", "worker": "精査"}])
+
+        used: list = []
+        with pytest.raises((ValueError, fastapi.HTTPException)):
+            asyncio.run(main._collect_items(
+                collect.get("news"), {}, {}, [], collect.sweeps_of(collect.get("news"))[0],
+                None, None, None, used,
+            ))
+
+        assert main._who_ran(used)["backend"] == "antigravity"
+
     def test_nothing_ran_leaves_the_record_alone(self):
         """AI を呼ばない回では書き換えない(既定の相手が並ぶのを防ぐ)。"""
         from app import main