ワーカーを、時計を待たずに起こせるようにする

枠が明いているうちに回しておきたい、が普通に起きる。次の起動まで待つと、
待っているあいだに他の依頼が枠を食う（実測で、外からの 1 回が 5 時間枠を
48 ポイント持っていった）。

押せば待ち行列の先頭が 1 本流れる。起こしたことになるので、次の起動は押した時刻から
間隔ぶん後になる。

断る理由は書き分ける。行列が空なのか枠が詰まっているのかで、次にすることが逆になる
（積むのを待つ / 窓が明くのを待つ）——「起きませんでした」だけでは、押した人に
どちらなのか読めない。

時計から回す道と同じ手順を通す（_flush_one）。書き写すと、片方だけ直したときに
拾い方や塊の扱いが食い違う。

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

Author: claude

CLAUDE.md

@@ -466,6 +466,12 @@ GeoNames 全世界地名辞典 = `geonames`(いずれも 348 言語版・195 か
         人に直させる価値が無い)
       - **収集を消したら行列からも外す**(`collect.remove`)。消えた収集を抱えた
         ままだと、そのワーカーは起こそうとして 404 を踏み続ける
+      - **時計を待たずに起こせる**(`main.wake_worker` / 画面の「今すぐ起こす」)。
+        **枠が明いているうちに回しておきたい、が普通に起きる** —— 次の起動まで待つと、
+        待っているあいだに他の依頼が枠を食う(実測で、外からの 1 回が 5 時間枠を
+        48 ポイント持っていった)。押せば行列の先頭が 1 本流れ、**そこから間隔を
+        数え直す**(起こしたことになる)。**断る理由は書き分ける** —— 行列が空なのか
+        枠が詰まっているのかで、次にすることが逆になる(積むのを待つ / 窓が明くのを待つ)
       - **節に「前回起きた・次に起きる・待ち行列」を出す**(`ai_workers._queue_html`)。
         **積まれているのに動かないなら**枠が詰まっているか起動待ち、**積まれていない
         なら**巡回の側がまだ積んでいない —— どちらなのかは、時刻と行列を並べないと

app/main.py

@@ -344,34 +344,71 @@ def _run_one_from_a_worker() -> bool:
         defined = workers.load()
     except ValueError:
         return False
-    for worker in defined:
-        batch = workers.queued(worker.name)
+    # **1 周で流すのは 1 本。** 取り込みは同時に 1 ジョブしか受けないので、
+    # 先に流せたワーカーで打ち切る(残りは次の周)
+    return any(_flush_one(worker, now) for worker in defined)
+
+
+def _flush_one(worker, now: datetime, wake: bool = False) -> bool:
+    """そのワーカーから 1 本流す。流したら True。
+
+    `wake` は**時計を待たずに起こす**(画面の「今すぐ起こす」)。枠が明いている
+    うちに回しておきたい、が普通に起きる —— 次の起動まで待つと、待っているあいだに
+    誰かが枠を食う。**起こした時刻は普通に控える**ので、そこから間隔を数え直す。
+    """
+    batch = workers.queued(worker.name)
+    if not batch:
+        return False
+    # **いま流している塊が先。** 無ければ、起動の時刻が来ていれば拾う
+    if not workers.claim_ready(worker.name):
+        if not wake and not _worker_due(worker, now):
+            return False
+        batch = workers.claim(worker.name, worker.per_run, _iso(now))
         if not batch:
-            continue
-        # **いま流している塊が先。** 無ければ、起動の時刻が来ていれば拾う
-        if not workers.claim_ready(worker.name):
-            if not _worker_due(worker, now):
-                continue
-            batch = workers.claim(worker.name, worker.per_run, _iso(now))
-            if not batch:
-                continue
-        entry = batch[0]
-        step = workers.pick(worker)
-        if step is None:
-            # **どれも詰まっていたら流さない。** 塊はそのまま残るので、
-            # 窓が明けた周で続きから流れる
-            continue
-        try:
-            start_collection_bake(entry["collection"], entry["sweep"])
-        except HTTPException as e:
-            # 取り込みが混んでいる・巡回が消えた。**塊からは外す** ——
-            # 消えた巡回を抱えたままだと、そのワーカーが二度と進まない
-            if e.status_code == 404:
-                workers.done(worker.name, entry["collection"], entry["sweep"])
             return False
-        workers.done(worker.name, entry["collection"], entry["sweep"])
-        return True
-    return False
+    entry = batch[0]
+    if workers.pick(worker) is None:
+        # **どれも詰まっていたら流さない。** 塊はそのまま残るので、
+        # 窓が明けた周で続きから流れる
+        return False
+    try:
+        start_collection_bake(entry["collection"], entry["sweep"])
+    except HTTPException as e:
+        # 取り込みが混んでいる・巡回が消えた。**塊からは外す** ——
+        # 消えた巡回を抱えたままだと、そのワーカーが二度と進まない
+        if e.status_code == 404:
+            workers.done(worker.name, entry["collection"], entry["sweep"])
+        return False
+    workers.done(worker.name, entry["collection"], entry["sweep"])
+    return True
+
+
+def wake_worker(name: str) -> dict:
+    """ワーカーを**時計を待たずに起こす**(画面の「今すぐ起こす」)。
+
+    **断る理由は書き分ける。** 押しても何も起きないときに「起きませんでした」
+    だけだと、行列が空なのか枠が詰まっているのかが押した人に読めない ——
+    どちらなのかで次にすることが逆になる(積むのを待つ / 窓が明くのを待つ)。
+    """
+    try:
+        worker = workers.get(name)
+    except ValueError as e:
+        raise HTTPException(409, {"error": str(e)}) from None
+    if worker is None:
+        raise HTTPException(404, {"error": f"ワーカー「{name}」がありません"})
+    if not workers.queued(name):
+        raise HTTPException(409, {
+            "error": f"ワーカー「{name}」の待ち行列は空です",
+            "hint": "巡回の側が自分を積むまで、起こしても流すものがありません",
+        })
+    if workers.pick(worker) is None:
+        raise HTTPException(429, _all_full(name))
+    if not _flush_one(worker, datetime.now(UTC), wake=True):
+        raise HTTPException(409, {
+            "error": f"ワーカー「{name}」から流せませんでした",
+            "hint": "取り込みが走っている最中かもしれません(少し置いてからもう一度)",
+        })
+    return {"ok": True, "worker": name}
 
 
 def _worker_due(worker, now: datetime) -> bool:

app/views/ai_workers.py

@@ -144,6 +144,7 @@ def _queue_html(worker: workers.Worker) -> str:
 <thead><tr><th>待ち行列(先に積まれた順)</th><th></th></tr></thead>
 <tbody>{rows}</tbody>
 </table>
+{_wake_form(worker, bool(waiting))}
 <p class="muted">
 <strong>次に起きる時刻は、前回「起きた」時刻から数えます</strong>(流し終えた時刻では
 ない)—— 塊を流し切るのに何周かかっても、次の起動は最初の起動から間隔ぶん後になる。<br>
@@ -153,6 +154,26 @@ def _queue_html(worker: workers.Worker) -> str:
 """
 
 
+def _wake_form(worker: workers.Worker, waiting: bool) -> str:
+    """時計を待たずに 1 本流す口。**待っているものが無ければ出さない**。
+
+    **枠が明いているうちに回しておきたい、が普通に起きる** —— 次の起動まで待つと、
+    待っているあいだに他の依頼が枠を食う(実測で、外からの 1 回が 5 時間枠を
+    48 ポイント持っていった)。押せば行列の先頭が 1 本流れ、**そこから間隔を
+    数え直す**(起こしたことになるので、次の起動は押した時刻からずれる)。
+    """
+    if not waiting:
+        return ('<p class="muted">待っているものが無いので、起こしても流すものが'
+                "ありません。</p>")
+    return (
+        f'<form class="init-form" method="post" action="/admin/ai/workers/wake">'
+        f'<input type="hidden" name="worker_name" value="{esc(worker.name)}">'
+        f'<button type="submit"'
+        f' title="間隔を待たずに、待ち行列の先頭を 1 本流します">今すぐ起こす</button>'
+        "</form>"
+    )
+
+
 def section_html(selects) -> str:
     """節ぜんたい。`selects` は相手・モデル・考える量のセレクトを作る 3 つ。
 
@@ -196,6 +217,23 @@ def section_html(selects) -> str:
 """
 
 
+@router.post("/admin/ai/workers/wake")
+async def wake_worker(request: Request):
+    """ワーカーを**時計を待たずに起こす**(行列の先頭を 1 本流す)。
+
+    枠が明いているうちに回しておきたい、が普通に起きる —— 次の起動まで待つと、
+    待っているあいだに他の依頼が枠を食う。
+
+    **断る理由は書き分ける**(`main.wake_worker`)。行列が空なのか枠が詰まって
+    いるのかで、次にすることが逆になる(積むのを待つ / 窓が明くのを待つ)。
+    """
+    from app.main import wake_worker as wake
+
+    form = await request.form()
+    wake(str(form.get("worker_name") or "").strip())
+    return RedirectResponse(BACK_TO_SECTION, status_code=303)
+
+
 @router.post("/admin/ai/workers")
 async def save_worker(request: Request):
     """ワーカー 1 つぶんを保存する。**その 1 つだけ**を書き換える。

tests/test_workers.py

@@ -496,6 +496,80 @@ async def broken(_asked, _messages):
         assert not workers.full_until("antigravity")
 
 
+class TestWakingItByHand:
+    """時計を待たずに 1 本流す(`main.wake_worker` / 画面の「今すぐ起こす」)。
+
+    **枠が明いているうちに回しておきたい、が普通に起きる** —— 次の起動まで待つと、
+    待っているあいだに他の依頼が枠を食う(実測で、外からの 1 回が 5 時間枠を
+    48 ポイント持っていった)。
+    """
+
+    @pytest.fixture
+    def baking(self, enabled, monkeypatch):
+        from app import main
+
+        started: list[tuple] = []
+        monkeypatch.setattr(
+            main, "start_collection_bake",
+            lambda name, sweep=None: started.append((name, sweep)),
+        )
+        return main, started
+
+    def test_it_runs_without_waiting_for_the_clock(self, baking):
+        """**間隔が来ていなくても流す。** それが押した意味。"""
+        main, started = baking
+        workers.save([workers.Worker("精査", (workers.Step("codex"),), interval_minutes=600)])
+        _quota("codex", 10.0)
+        workers.enqueue("精査", "news", "ざっと", "2026-01-01T00:00:00+00:00")
+        workers.claim("精査", 1, "2099-01-01T00:00:00+00:00")
+        workers.done("精査", "news", "ざっと")
+        workers.enqueue("精査", "news", "整理", "2026-01-01T00:00:00+00:00")
+
+        # 時計では起きない（前回起きたのが未来の時刻になっている）
+        assert not main._run_one_from_a_worker()
+
+        main.wake_worker("精査")
+
+        assert started == [("news", "整理")]
+
+    def test_an_empty_queue_says_so(self, baking):
+        """**理由を書き分ける。** 行列が空なのか枠が詰まっているのかで、
+        次にすることが逆になる(積むのを待つ / 窓が明くのを待つ)。
+        """
+        import fastapi
+
+        main, _started = baking
+        workers.save([workers.Worker("精査", (workers.Step("codex"),))])
+        _quota("codex", 10.0)
+
+        with pytest.raises(fastapi.HTTPException) as got:
+            main.wake_worker("精査")
+
+        assert got.value.status_code == 409
+        assert "待ち行列は空" in got.value.detail["error"]
+
+    def test_all_crowded_says_so(self, baking):
+        import fastapi
+
+        main, _started = baking
+        workers.save([workers.Worker("精査", (workers.Step("codex"),))])
+        _quota("codex", 95.0)
+        workers.enqueue("精査", "news", "ざっと", "2026-01-01T00:00:00+00:00")
+
+        with pytest.raises(fastapi.HTTPException) as got:
+            main.wake_worker("精査")
+
+        assert got.value.status_code == 429
+
+    def test_an_unknown_worker_is_404(self, baking):
+        import fastapi
+
+        main, _started = baking
+        with pytest.raises(fastapi.HTTPException) as got:
+            main.wake_worker("いない")
+        assert got.value.status_code == 404
+
+
 class TestWhoActuallyRan:
     """控えに残すのは、決めた相手ではなく**頼んだ相手**。