From fd61f9f020d0b872f8710d35b8a226f9ae12bfc9 Mon Sep 17 00:00:00 2001 From: ogt Date: Thu, 9 Jul 2026 23:44:23 +0800 Subject: [PATCH] fix(agents): prioritize consumer context coverage readback --- ...gram_alert_monitoring_coverage_readback.py | 25 +++++++------------ 1 file changed, 9 insertions(+), 16 deletions(-) diff --git a/apps/api/src/services/telegram_alert_monitoring_coverage_readback.py b/apps/api/src/services/telegram_alert_monitoring_coverage_readback.py index 1bf5007dd..86995bf37 100644 --- a/apps/api/src/services/telegram_alert_monitoring_coverage_readback.py +++ b/apps/api/src/services/telegram_alert_monitoring_coverage_readback.py @@ -101,22 +101,15 @@ async def load_latest_telegram_alert_monitoring_coverage_readback( ) _require_safe_boundaries(monitoring_inventory, monitoring_readback_plan) - ( - matrix, - verifier, - ai_alert_readback, - runtime_log_readback, - consumer_readback, - source_contract, - ) = ( - await asyncio.gather( - _load_telegram_matrix_readback(project_id=project_id), - _load_post_apply_verifier_readback(project_id=project_id), - _load_ai_alert_card_delivery(project_id=project_id), - _load_runtime_log_readback(project_id=project_id), - _load_log_controlled_writeback_consumer_readback(project_id=project_id), - asyncio.to_thread(_inspect_source_contract, repo_root), - ) + matrix, consumer_readback, source_contract = await asyncio.gather( + _load_telegram_matrix_readback(project_id=project_id), + _load_log_controlled_writeback_consumer_readback(project_id=project_id), + asyncio.to_thread(_inspect_source_contract, repo_root), + ) + verifier, ai_alert_readback, runtime_log_readback = await asyncio.gather( + _load_post_apply_verifier_readback(project_id=project_id), + _load_ai_alert_card_delivery(project_id=project_id), + _load_runtime_log_readback(project_id=project_id), ) return build_telegram_alert_monitoring_coverage_readback(