From 6ba4d9f0992c69eb5274bf454f9bbff13f8e9bde Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 23:23:40 +0800 Subject: [PATCH] =?UTF-8?q?K3b=EF=BC=9A=E5=8F=8D=E6=96=B9=E5=AE=A1?= =?UTF-8?q?=E7=A8=BF=E6=9F=A5=E6=95=B0=E6=8D=AE=E6=BA=90=E7=B1=BB=E5=9E=8B?= =?UTF-8?q?=E6=97=B6=E7=9B=B4=E6=8E=A5=E7=94=A8=E6=95=B4=E4=BB=BD=E6=8A=A5?= =?UTF-8?q?=E5=91=8A=E7=94=A8=E5=88=B0=E7=9A=84=E6=BA=90=EF=BC=8C=E4=B8=8D?= =?UTF-8?q?=E5=86=8D=E9=80=90=E4=BB=B6=E5=8F=96=E5=B7=A5=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit claim_sources 已经认全了查询的、合并查询合并的、指标输入取自的、表和字段的数据源,_kinds 不必再把目录里每件工件都取一遍。 --- backend/app/engine/nodes/challenge.py | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/backend/app/engine/nodes/challenge.py b/backend/app/engine/nodes/challenge.py index f9ddfff3..6a2ea01c 100644 --- a/backend/app/engine/nodes/challenge.py +++ b/backend/app/engine/nodes/challenge.py @@ -817,15 +817,11 @@ class _Review: if isinstance(entry, dict) and entry.get("kind") == "query") async def _kinds(self, names: Iterable[str]) -> dict[str, Any]: - """这几个数据源的类型(摘录按 SQL 认改了名字的遮罩列时用)。快照记的数据源也算上(旧台账条目没记数据源)。""" + """这几个数据源的类型(摘录按 SQL 认改了名字的遮罩列时按它的方言解析)。names 是整份报告用到的数据源 + (claim_sources:查询的、合并查询合并的、指标输入取自的、表和字段的)。""" from app.engine.inquiry import _source_kinds # inquiry 导入了这个模块,用到时再导入 - wanted = set(names) - for entry in self.catalog.values(): - snapshot = self.fetch(entry.get("artifact")) if isinstance(entry, dict) else None - if isinstance(snapshot, dict) and snapshot.get("source"): - wanted.add(str(snapshot["source"])) - return await _source_kinds(wanted) + return await _source_kinds(names) async def _store(self, record: dict[str, Any]) -> str | None: try: