🟡 Medium Priority

executor.py 第 77-81 行新增的 logger.info(...) 将完整的 runner_kw.get('headers', {}) 以 INFO 级别写入日志，未对 token、authorization、cookie 等敏感 header 做任何脱敏处理。body 字段有 [:200] 截断，但 headers 完全没有截断或脱敏。

对比 versatile_proxy.py 中 _log_request 使用 _SENSITIVE_HEADERS 集合对 curl 命令中的敏感 header 做 *** 替换，且请求头日志使用 DEBUG 级别。此处以 INFO 级别（生产环境通常开启）记录完整 headers，若上游 a2a_service 传入的 headers 中包含 [REDACTED]、session cookie 等，将直接写入日志文件。

风险：日志被非授权人员/系统访问时泄露凭据。

建议：将日志级别降为 DEBUG，或对 headers 做脱敏处理（过滤 token/authorization/cookie 等敏感 key），或只记录 header keys 而非 values。

🟡 Medium Priority

VersatileA2AGateway._on_stream_end 第 182 行使用真值判断 ctx.execution_result 来决定是否产出 execution_completed 终态事件。但 _handle_artifact_update 在处理非文本 parts（如纯文件 parts）时，仍会将空字符串 "" 存入 ctx.artifact_texts（第 230 行），并设置 ctx.last_artifact_id（第 231 行）。当 TASK_STATE_COMPLETED 到来时，_handle_status_update 会从 artifact_texts 中取出空字符串赋给 ctx.execution_result（第 259 行）。

此时 ctx.is_failed or ctx.execution_result → False or "" → ""（falsy），_on_stream_end 返回 []，不产出 execution_completed。executor 的 for 循环结束后触发兜底逻辑（executor.py 第 133 行），以 result=None 完成任务——丢失了原本可能从 status.message 降级提取到的有效文本。

触发条件：A2A Gateway 返回的 artifact 中 parts 只有非 text 类型（如 {"type":"file", ...}），同时 TASK_STATE_COMPLETED 的 message 中包含可用于降级提取的文本。

建议：将 ctx.execution_result 的真值检查改为 ctx.execution_result is not None，以区分"已设置空结果"与"未设置结果"两种语义。ctx.execution_result 初始为 None（VersatileStreamCtx 第 36 行），只有被明确赋值后才应视为有结果。

🟡 Medium Priority

_on_stream_end 第 182 行的条件 if ctx.is_failed or ctx.execution_result: 在 ctx.execution_result 为空字符串 "" 时求值为 False or "" → ""（falsy），导致整个方法返回空列表 []。

触发条件：A2A Gateway 返回 TASK_STATE_COMPLETED 但无 artifact 且 status message 也为空，或 artifact 累积的文本恰为空串。此时 ctx.completed=True、ctx.is_failed=False、ctx.execution_result=""。

后果：适配器层不产出任何终态事件，完全依赖 executor 的 if not terminal_sent 兜底逻辑发送 result=None 的 completed 事件。虽然 executor 有兜底，但适配器自身的契约被打破（completed 状态不产生事件），且当 executor 兜底逻辑未来变更时可能引入回归。

修复方向：在条件中增加对 ctx.completed 的判断，确保 completed 状态下始终产出 ExecutionCompletedContent 事件。

建议：将条件改为 if ctx.is_failed or ctx.execution_result or ctx.completed:，或在条件体内明确处理 completed-but-no-result 情况，确保产出 ExecutionCompletedContent(is_failed=False, result="", error_message="") 事件。

🟡 Medium Priority

在 VersatileA2AGateway._extract_text_from_status_message 方法中（第 330-334 行），parts = message.get("parts", []) 获得的 parts 可能不是列表（例如上游返回 {"parts": {"unexpected": "dict"}}），后续的生成器表达式 for part in parts 将抛出 TypeError: 'dict' object is not iterable。

相比之下，_handle_artifact_update 方法（第 218 行）已对此做了防御：if not isinstance(parts, list): parts = []。同样的防护应在 _extract_text_from_status_message 中添加，保持一致性并避免运行时崩溃。

触发条件：A2A Gateway 返回的 taskStatusUpdate.message.parts 字段为非列表值（如 dict、字符串）。

建议：在迭代 parts 前增加 isinstance(parts, list) 检查，与 _handle_artifact_update 保持一致。

【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：pylint，请Committer检视其合理性。