Merge remote-tracking branch 'origin/main' into codex/p0-006-ai-log-triage-20260709

apps/api/tests/test_awoooi_priority_work_order_readback_api.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+# ruff: noqa: E402
 import asyncio
 import json
 import os
@@ -446,23 +447,35 @@ def test_awoooi_priority_work_order_readback_surfaces_gitea_bundle_truth():
     assert payload["operation_boundaries"]["workflow_dispatch_performed"] is False
     assert payload["operation_boundaries"]["host_write_performed"] is False
     inserted_items = payload["commander_inserted_requirement_work_items"]
-    assert len(inserted_items) == 55
+    priority_counts = {
+        priority: sum(1 for item in inserted_items if item["priority"] == priority)
+        for priority in ("P0", "P1", "P2", "P3")
+    }
+    status_counts = {
+        status: sum(1 for item in inserted_items if item["status"] == status)
+        for status in ("done", "in_progress", "blocked", "pending", "deferred")
+    }
+    assert len(inserted_items) == payload["summary"][
+        "commander_inserted_requirement_work_item_count"
+    ]
     assert inserted_items[0]["id"] == "CIR-P0-001"
     assert inserted_items[-1]["id"] == "CIR-P3-NON-001"
-    assert [item["order"] for item in inserted_items] == list(range(1, 56))
+    assert [item["order"] for item in inserted_items] == list(
+        range(1, len(inserted_items) + 1)
+    )
     assert all(item["acceptance"] for item in inserted_items)
-    assert payload["summary"]["commander_inserted_requirement_work_item_count"] == 55
-    assert payload["summary"]["commander_inserted_requirement_p0_count"] == 34
-    assert payload["summary"]["commander_inserted_requirement_p1_count"] == 14
-    assert payload["summary"]["commander_inserted_requirement_p2_count"] == 5
-    assert payload["summary"]["commander_inserted_requirement_p3_count"] == 2
-    assert payload["summary"]["commander_inserted_requirement_done_count"] == 9
-    assert payload["summary"]["commander_inserted_requirement_in_progress_count"] == 27
-    assert payload["summary"]["commander_inserted_requirement_next_id"] == "CIR-P0-004"
-    assert payload["rollups"]["commander_inserted_requirement_blocked_count"] == 1
+    assert payload["summary"]["commander_inserted_requirement_p0_count"] == priority_counts["P0"]
+    assert payload["summary"]["commander_inserted_requirement_p1_count"] == priority_counts["P1"]
+    assert payload["summary"]["commander_inserted_requirement_p2_count"] == priority_counts["P2"]
+    assert payload["summary"]["commander_inserted_requirement_p3_count"] == priority_counts["P3"]
+    assert payload["summary"]["commander_inserted_requirement_done_count"] == status_counts["done"]
+    assert payload["summary"]["commander_inserted_requirement_in_progress_count"] == status_counts["in_progress"]
+    assert payload["summary"]["commander_inserted_requirement_next_id"] == "CIR-P0-006"
+    assert payload["rollups"]["commander_inserted_requirement_blocked_count"] == status_counts["blocked"]
     inserted_by_id = {item["id"]: item for item in inserted_items}
     assert inserted_by_id["CIR-P0-001"]["status"] == "done"
     assert inserted_by_id["CIR-P0-002"]["status"] == "done"
+    assert inserted_by_id["CIR-P0-004"]["status"] == "done"
     assert inserted_by_id["CIR-P0-011"]["status"] == "done"
     assert inserted_by_id["CIR-P0-AILOOP-001"]["lane"] == (
         "ai_loop_agent_mainline"
@@ -499,6 +512,9 @@ def test_awoooi_priority_work_order_readback_surfaces_gitea_bundle_truth():
     assert inserted_by_id["CIR-P1-KM-002"]["lane"] == (
         "log_km_mcp_rag_playbook_integration"
     )
+    assert inserted_by_id["CIR-P1-AI-002"]["lane"] == (
+        "agent_market_research_version_lifecycle"
+    )
     assert inserted_by_id["CIR-P1-OPENCLAW-001"]["lane"] == (
         "openclaw_live_ops_space"
     )
@@ -1381,15 +1397,24 @@ def test_awoooi_priority_work_order_readback_endpoint_returns_snapshot(
         "P0-006-AI-LOOP-CURRENT-BLOCKER-EXECUTION-QUEUE"
     )
     assert "do not reopen Harbor 502" in data["next_execution_order"][0]
-    assert data["summary"]["commander_inserted_requirement_work_item_count"] == 55
-    assert data["summary"]["commander_inserted_requirement_done_count"] == 9
-    assert data["summary"]["commander_inserted_requirement_in_progress_count"] == 27
-    assert data["summary"]["commander_inserted_requirement_next_id"] == "CIR-P0-004"
-    assert data["commander_inserted_requirement_work_items"][1]["id"] == (
-        "CIR-P0-002"
+    inserted_items = data["commander_inserted_requirement_work_items"]
+    status_counts = {
+        status: sum(1 for item in inserted_items if item["status"] == status)
+        for status in ("done", "in_progress", "blocked", "pending", "deferred")
+    }
+    assert data["summary"]["commander_inserted_requirement_work_item_count"] == len(
+        inserted_items
     )
-    assert data["commander_inserted_requirement_work_items"][1]["priority"] == "P0"
-    assert data["commander_inserted_requirement_work_items"][1]["visible_surface"] == (
+    assert data["summary"]["commander_inserted_requirement_done_count"] == status_counts[
+        "done"
+    ]
+    assert data["summary"]["commander_inserted_requirement_in_progress_count"] == (
+        status_counts["in_progress"]
+    )
+    assert data["summary"]["commander_inserted_requirement_next_id"] == "CIR-P0-006"
+    assert inserted_items[1]["id"] == "CIR-P0-002"
+    assert inserted_items[1]["priority"] == "P0"
+    assert inserted_items[1]["visible_surface"] == (
         "/zh-TW/awooop/work-items"
     )
     assert data["summary"]["ai_automation_node_receipt_schema_version"] == (
@@ -2226,18 +2251,18 @@ def test_awoooi_priority_work_order_readback_allows_parallel_mainline_on_stockpl
         "external_stockplatform_data_retry_wait"
     )
     assert parallel["retry_readback_at"]
-    assert parallel["parallel_work_item"]["id"] == "CIR-P0-004"
+    assert parallel["parallel_work_item"]["id"] == "CIR-P0-007"
     assert parallel["parallel_work_item"]["priority"] == "P0"
     assert parallel["report_contract"]["current_p0"] == "P0-006"
     assert "fake_stockplatform_freshness_marker" in parallel["forbidden_actions"]
     assert "db_write_or_restore_from_this_wait_lane" in parallel["forbidden_actions"]
     assert state["parallel_mainline_execution_enabled"] is True
-    assert state["parallel_mainline_work_item_id"] == "CIR-P0-004"
+    assert state["parallel_mainline_work_item_id"] == "CIR-P0-007"
     assert payload["summary"]["parallel_mainline_execution_enabled"] is True
-    assert payload["summary"]["parallel_mainline_work_item_id"] == "CIR-P0-004"
+    assert payload["summary"]["parallel_mainline_work_item_id"] == "CIR-P0-007"
     assert payload["summary"]["parallel_mainline_work_item_priority"] == "P0"
     assert payload["rollups"]["parallel_mainline_execution_enabled"] is True
-    assert payload["rollups"]["parallel_mainline_work_item_id"] == "CIR-P0-004"
+    assert payload["rollups"]["parallel_mainline_work_item_id"] == "CIR-P0-007"
 
 
 def test_awoooi_priority_work_order_readback_routes_stockplatform_ai_recommendations():