diff --git a/apps/api/src/services/agent_market_watch.py b/apps/api/src/services/agent_market_watch.py
index ec94e16c..7705ffd5 100644
--- a/apps/api/src/services/agent_market_watch.py
+++ b/apps/api/src/services/agent_market_watch.py
@@ -19,7 +19,7 @@ from dataclasses import dataclass
from datetime import datetime, timezone
from typing import Any
from urllib.error import HTTPError, URLError
-from urllib.parse import urljoin
+from urllib.parse import urljoin, urlparse
from urllib.request import Request, urlopen
FetchSource = Callable[[str, int], "FetchedSource"]
@@ -234,9 +234,24 @@ def _evaluate_source(
}
fetched = fetcher(url, timeout_seconds)
+ previous = previous_sources.get((candidate_id, source_id), {})
+ if _is_github_rate_limited(url, fetched) and previous:
+ return {
+ "source_id": source_id,
+ "type": source_type,
+ "url": url,
+ "status": "carried_forward_rate_limited",
+ "http_status": fetched.http_status,
+ "version": previous.get("version"),
+ "published_at": previous.get("published_at"),
+ "content_hash": previous.get("content_hash"),
+ "changed_since_reference": False,
+ "reference_version": reference_version,
+ "error": None,
+ "carried_forward_from_previous": True,
+ }
parsed = _parse_source(source_type, fetched.body) if fetched.body else {}
content_hash = _content_hash(fetched.body, source_type) if fetched.body else None
- previous = previous_sources.get((candidate_id, source_id), {})
version = parsed.get("version")
published_at = parsed.get("published_at")
changed = _changed_since_reference(
@@ -260,6 +275,16 @@ def _evaluate_source(
}
+def _is_github_rate_limited(url: str, fetched: FetchedSource) -> bool:
+ if fetched.status != "error" or fetched.http_status != 403:
+ return False
+ host = urlparse(url).netloc.lower()
+ if host != "api.github.com":
+ return False
+ body = fetched.body.decode("utf-8", errors="ignore").lower()
+ return "rate limit" in body or "api rate limit exceeded" in body
+
+
def _parse_source(source_type: str, body: bytes) -> dict[str, str | None]:
if source_type == "pypi":
payload = _loads_json(body)
diff --git a/apps/api/tests/test_agent_market_watch.py b/apps/api/tests/test_agent_market_watch.py
index 2b9330a8..6b7a1858 100644
--- a/apps/api/tests/test_agent_market_watch.py
+++ b/apps/api/tests/test_agent_market_watch.py
@@ -333,3 +333,64 @@ def test_versioned_source_ignores_metadata_hash_noise_when_version_is_unchanged(
assert report["summary"]["changed_candidates"] == 0
assert report["candidates"][0]["sources"][0]["version"] == "1.2.3"
assert report["candidates"][0]["sources"][0]["changed_since_reference"] is False
+
+
+def test_github_rate_limit_carries_forward_previous_source_without_failure():
+ registry = {
+ "schema_version": "agent_market_watch_sources_v1",
+ "policy": {"replacement_decision_allowed": False},
+ "candidates": [
+ {
+ "candidate_id": "rate_limited_candidate",
+ "display_name": "Rate Limited Candidate",
+ "sources": [
+ {
+ "source_id": "github_release",
+ "type": "github_release",
+ "url": "https://api.github.com/repos/example/project/releases/latest",
+ }
+ ],
+ }
+ ],
+ }
+ previous_report = {
+ "candidates": [
+ {
+ "candidate_id": "rate_limited_candidate",
+ "sources": [
+ {
+ "source_id": "github_release",
+ "version": "v1.2.3",
+ "published_at": "2026-06-25T00:00:00Z",
+ "content_hash": "previous-hash",
+ }
+ ],
+ }
+ ]
+ }
+
+ def fetcher(_url: str, _timeout: int) -> FetchedSource:
+ return FetchedSource(
+ status="error",
+ http_status=403,
+ body=b'{"message":"API rate limit exceeded"}',
+ error="http_403",
+ )
+
+ report = run_agent_market_watch(
+ registry,
+ registry_path="registry.json",
+ mode="live",
+ previous_report=previous_report,
+ fetcher=fetcher,
+ generated_at="2026-06-26T00:00:00+00:00",
+ )
+
+ source = report["candidates"][0]["sources"][0]
+ assert report["summary"]["failure_count"] == 0
+ assert report["summary"]["changed_candidates"] == 0
+ assert source["status"] == "carried_forward_rate_limited"
+ assert source["version"] == "v1.2.3"
+ assert source["changed_since_reference"] is False
+ assert source["error"] is None
+ assert source["carried_forward_from_previous"] is True
diff --git a/apps/api/tests/test_ai_agent_market_radar_readback.py b/apps/api/tests/test_ai_agent_market_radar_readback.py
index cd99511b..85a29c95 100644
--- a/apps/api/tests/test_ai_agent_market_radar_readback.py
+++ b/apps/api/tests/test_ai_agent_market_radar_readback.py
@@ -13,12 +13,13 @@ def test_ai_agent_market_radar_readback_committed_snapshot_is_safe():
assert payload["schema_version"] == "ai_agent_market_radar_readback_v1"
assert payload["summary"]["overall_completion_percent"] == 42.2
assert payload["summary"]["market_candidates"] == 13
- assert payload["summary"]["market_sources"] == 34
- assert payload["summary"]["changed_candidates"] == 13
- assert payload["summary"]["integration_blocked_candidates"] == 13
+ assert payload["summary"]["market_sources"] == 36
+ assert payload["summary"]["changed_candidates"] == 5
+ assert payload["summary"]["integration_blocked_candidates"] == 5
+ assert payload["summary"]["source_failures"] == 0
assert payload["summary"]["replacement_decisions_approved"] == 0
assert "gitea_main_deploy_marker" not in payload["source_scope"]
- assert payload["source_scope"]["gitea_main_evidence_basis_commit"] == "279f9531"
+ assert payload["source_scope"]["gitea_main_evidence_basis_commit"] == "61cf5024"
policy = payload["policy"]
assert policy["read_only"] is True
@@ -58,4 +59,4 @@ def test_ai_agent_market_radar_readback_contains_market_practice_plan():
}
assert candidates["openclaw_incumbent"]["gate_status"] == "production_baseline"
assert candidates["nemo_nemotron_fabric"]["gate_status"] == "integration_blocked"
- assert candidates["langgraph_incident_kernel"]["gate_status"] == "integration_blocked"
+ assert candidates["langgraph_incident_kernel"]["gate_status"] == "registered_no_review"
diff --git a/apps/api/tests/test_ai_agent_market_radar_readback_api.py b/apps/api/tests/test_ai_agent_market_radar_readback_api.py
index 291d308f..a3173844 100644
--- a/apps/api/tests/test_ai_agent_market_radar_readback_api.py
+++ b/apps/api/tests/test_ai_agent_market_radar_readback_api.py
@@ -20,9 +20,10 @@ def test_ai_agent_market_radar_readback_endpoint_returns_committed_snapshot():
assert data["schema_version"] == "ai_agent_market_radar_readback_v1"
assert data["summary"]["overall_completion_percent"] == 42.2
assert data["summary"]["market_candidates"] == 13
- assert data["summary"]["market_sources"] == 34
- assert data["summary"]["changed_candidates"] == 13
- assert data["summary"]["integration_blocked_candidates"] == 13
+ assert data["summary"]["market_sources"] == 36
+ assert data["summary"]["changed_candidates"] == 5
+ assert data["summary"]["integration_blocked_candidates"] == 5
+ assert data["summary"]["source_failures"] == 0
assert data["summary"]["replacement_decisions_approved"] == 0
assert data["policy"]["openclaw_replacement_approved"] is False
assert data["policy"]["telegram_send_approved"] is False
diff --git a/apps/api/tests/test_ai_technology_radar_readback.py b/apps/api/tests/test_ai_technology_radar_readback.py
index 145eb1f5..8ca8bfef 100644
--- a/apps/api/tests/test_ai_technology_radar_readback.py
+++ b/apps/api/tests/test_ai_technology_radar_readback.py
@@ -13,15 +13,17 @@ def test_ai_technology_radar_readback_committed_snapshot_is_safe():
assert payload["schema_version"] == "ai_technology_radar_readback_v1"
assert payload["summary"]["overall_completion_percent"] == 42.2
assert payload["summary"]["ai_technology_radar_completion_percent"] == 100.0
- assert payload["summary"]["technology_count"] == 20
+ assert payload["summary"]["technology_count"] == 21
assert payload["summary"]["technology_area_count"] == 6
- assert payload["summary"]["source_count"] == 47
+ assert payload["summary"]["source_count"] == 52
assert payload["summary"]["source_failures"] == 0
- assert payload["summary"]["high_priority_count"] == 14
+ assert payload["summary"]["changed_technologies"] == 5
+ assert payload["summary"]["review_queue_count"] == 5
+ assert payload["summary"]["high_priority_count"] == 15
assert payload["summary"]["rolling_update_status"] == (
"near_real_time_watch_ready_integration_gated"
)
- assert payload["source_scope"]["gitea_main_evidence_basis_commit"] == "683428bd"
+ assert payload["source_scope"]["gitea_main_evidence_basis_commit"] == "61cf5024"
policy = payload["policy"]
assert policy["read_only"] is True
@@ -59,3 +61,22 @@ def test_ai_technology_radar_readback_contains_roles_and_cadence():
assert payload["report_contract"]["api_endpoint"] == (
"/api/v1/agents/ai-technology-radar-readback"
)
+
+
+def test_ai_technology_radar_readback_contains_market_source_alignment():
+ payload = load_latest_ai_technology_radar_readback()
+
+ queue = {row["technology_id"]: row for row in payload["high_priority_review_queue"]}
+ assert "modelcontextprotocol_sdk" in queue
+ assert "a2a_protocol" in queue
+ assert queue["modelcontextprotocol_sdk"]["gate_status"] == (
+ "scorecard_required_before_integration"
+ )
+
+ alignment_sources = {row["source"] for row in payload["primary_source_alignment"]}
+ assert "https://modelcontextprotocol.io/specification/2025-06-18" in alignment_sources
+ assert "https://a2a-protocol.org/latest/" in alignment_sources
+ assert (
+ "https://opentelemetry.io/docs/specs/semconv/registry/attributes/gen-ai/"
+ in alignment_sources
+ )
diff --git a/apps/api/tests/test_ai_technology_radar_readback_api.py b/apps/api/tests/test_ai_technology_radar_readback_api.py
index ddc343b5..aff2d19a 100644
--- a/apps/api/tests/test_ai_technology_radar_readback_api.py
+++ b/apps/api/tests/test_ai_technology_radar_readback_api.py
@@ -20,9 +20,12 @@ def test_ai_technology_radar_readback_endpoint_returns_committed_snapshot():
assert data["schema_version"] == "ai_technology_radar_readback_v1"
assert data["summary"]["overall_completion_percent"] == 42.2
assert data["summary"]["ai_technology_radar_completion_percent"] == 100.0
- assert data["summary"]["technology_count"] == 20
- assert data["summary"]["source_count"] == 47
+ assert data["summary"]["technology_count"] == 21
+ assert data["summary"]["source_count"] == 52
+ assert data["summary"]["changed_technologies"] == 5
+ assert data["summary"]["review_queue_count"] == 5
assert data["summary"]["source_failures"] == 0
+ assert len(data["primary_source_alignment"]) == 6
assert data["policy"]["read_only"] is True
assert data["policy"]["sdk_installation_approved"] is False
assert data["policy"]["telegram_send_approved"] is False
diff --git a/apps/web/messages/en.json b/apps/web/messages/en.json
index 7fb74c24..617e7ade 100644
--- a/apps/web/messages/en.json
+++ b/apps/web/messages/en.json
@@ -3317,9 +3317,21 @@
"nearRealTime": "近即時監控",
"reviewQueue": "審核佇列",
"reviewQueueValue": "待審 {queue} / 高優先 {high} / 變更 {changed}",
+ "highPriorityTitle": "高優先市場審核佇列",
+ "emptyReviewQueue": "目前沒有高優先審核項目",
+ "primarySourceTitle": "官方 Primary Source 對齊",
"domainsTitle": "市場技術領域",
"rollingTitle": "日週月報與滾動更新控制",
"rolesTitle": "專業 Agent 分工",
+ "reviewLabels": {
+ "nextGate": "下一個 Gate",
+ "reviewNeeds": "審核需求",
+ "cost": "成本",
+ "dependency": "依賴",
+ "security": "資安",
+ "awoooiGate": "AWOOOI Gate",
+ "agentAssignment": "Agent 分工"
+ },
"metrics": {
"progress": "雷達完成度",
"technologies": "監控技術",
diff --git a/apps/web/messages/zh-TW.json b/apps/web/messages/zh-TW.json
index 7fb74c24..617e7ade 100644
--- a/apps/web/messages/zh-TW.json
+++ b/apps/web/messages/zh-TW.json
@@ -3317,9 +3317,21 @@
"nearRealTime": "近即時監控",
"reviewQueue": "審核佇列",
"reviewQueueValue": "待審 {queue} / 高優先 {high} / 變更 {changed}",
+ "highPriorityTitle": "高優先市場審核佇列",
+ "emptyReviewQueue": "目前沒有高優先審核項目",
+ "primarySourceTitle": "官方 Primary Source 對齊",
"domainsTitle": "市場技術領域",
"rollingTitle": "日週月報與滾動更新控制",
"rolesTitle": "專業 Agent 分工",
+ "reviewLabels": {
+ "nextGate": "下一個 Gate",
+ "reviewNeeds": "審核需求",
+ "cost": "成本",
+ "dependency": "依賴",
+ "security": "資安",
+ "awoooiGate": "AWOOOI Gate",
+ "agentAssignment": "Agent 分工"
+ },
"metrics": {
"progress": "雷達完成度",
"technologies": "監控技術",
diff --git a/apps/web/src/app/[locale]/governance/tabs/agent-market-tab.tsx b/apps/web/src/app/[locale]/governance/tabs/agent-market-tab.tsx
index d9aad99e..bd927742 100644
--- a/apps/web/src/app/[locale]/governance/tabs/agent-market-tab.tsx
+++ b/apps/web/src/app/[locale]/governance/tabs/agent-market-tab.tsx
@@ -59,6 +59,15 @@ type ProfessionalJudgmentPreset = {
question: string
escalation: string
}
+type TechnologyReviewLabels = {
+ nextGate: string
+ reviewNeeds: string
+ cost: string
+ dependency: string
+ security: string
+ awoooiGate: string
+ agentAssignment: string
+}
function formatDateTime(value: string): string {
const date = new Date(value)
@@ -88,6 +97,14 @@ function formatTechnologyArea(value: string): string {
return TECHNOLOGY_AREA_LABELS[value] ?? value.replace(/_/g, ' ')
}
+function formatSourceHost(value: string): string {
+ try {
+ return new URL(value).hostname.replace(/^www\./, '')
+ } catch {
+ return value
+ }
+}
+
function normalizeAgentName(value: string): string {
const normalized = value.toLowerCase()
if (normalized.includes('openclaw')) return 'openclaw'
@@ -396,6 +413,84 @@ function ProfessionalAgentRoleCard({ role }: { role: AiTechnologyRadarReadback['
)
}
+function HighPriorityReviewCard({
+ item,
+ labels,
+}: {
+ item: AiTechnologyRadarReadback['high_priority_review_queue'][number]
+ labels: TechnologyReviewLabels
+}) {
+ return (
+
+
+
+
+ {item.display_name}
+
+
+
+
+
+
+
+
+
+ {item.next_gate}
+
+
+
+
+
+
+
+
+
+
+
+ {item.practice}
+
+
+
+
+
+
+
+ {item.agent_assignment}
+
+
+
+
+
+
+ {t('technologyRadar.highPriorityTitle')}
+
+
+ {technologyRadar.high_priority_review_queue.length > 0 ? (
+ technologyRadar.high_priority_review_queue.map(item => (
+
+ ))
+ ) : (
+
+
+
+ )}
+
+
+
+
+
+ {t('technologyRadar.primarySourceTitle')}
+
+
+
+ {technologyRadar.primary_source_alignment.map(item => (
+
+ ))}
+