From 7e4a3f66b30ee7ab56b2b066790a029d4a4ed6e8 Mon Sep 17 00:00:00 2001 From: chakcy <947105045@qq.com> Date: Sat, 22 Aug 2026 03:54:02 +0800 Subject: [PATCH] =?UTF-8?q?modify:=20json=20=E8=A7=A3=E6=9E=90=E4=BC=98?= =?UTF-8?q?=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/chongming_worker/runtime.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/chongming_worker/runtime.py b/src/chongming_worker/runtime.py index 0bf3893..975d8c7 100644 --- a/src/chongming_worker/runtime.py +++ b/src/chongming_worker/runtime.py @@ -142,8 +142,7 @@ async def create_worker( if not matched and methods: matched = methods[0] # 降级到第一个 if not matched: - query.reply( - key_expr=query.key_expr, + query.reply_err( payload=json.dumps({"error": f"No method for {subject}"}).encode("utf-8") ) return @@ -169,7 +168,7 @@ async def create_worker( logger.debug("[Worker] %s 回复 %s %s", worker_id, matched.method, subject) except Exception as e: if matched is not None and matched.stream: - # 流式端点错误：以 {"error": ...} 收尾块结束流 + # 流式端点错误：以 {"error": ...} 收尾块结束流（流式语义不变） query.reply( key_expr=query.key_expr, payload=orjson.dumps({"error": str(e)}) @@ -181,8 +180,9 @@ async def create_worker( "error": str(e), "worker": worker_id } - query.reply( - key_expr=query.key_expr, + # 框架错误走 reply_err 通道：网关零解析判定失败（映射 503）； + # 载荷保持原错误信封结构，旧网关仍按普通回复透传（兼容） + query.reply_err( payload=json.dumps(error_response).encode("utf-8") ) logger.error("[Worker] %s 异常 %s: %s", worker_id, subject, e)