dirtydishes/islandflow
1
0
Fork 0
Code Issues 2 Pull requests 4 Projects Releases Packages Wiki Activity Actions 1

Fix dark evidence resolution and improve trace readability

Browse source
This commit is contained in:
dirtydishes 2026-04-27 15:52:44 -04:00
parent a45d5c85f6
commit 2229c8c09c
2 changed files with 103 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

28
packages/storage/src/clickhouse.ts
View file

@ -1317,8 +1317,34 @@ export const fetchEquityPrintJoinsByIds = async (
return [];
}
const joinIds = new Set<string>();
const printTraceIds = new Set<string>();
for (const id of uniqueIds) {
joinIds.add(id);
if (id.startsWith("equityjoin:")) {
const trace = id.slice("equityjoin:".length);
if (trace) {
printTraceIds.add(trace);
}
} else {
joinIds.add(`equityjoin:${id}`);
printTraceIds.add(id);
}
}
const joinIdList = Array.from(joinIds);
const printTraceList = Array.from(printTraceIds);
const whereParts = [
`id IN (${buildStringList(joinIdList)})`,
`trace_id IN (${buildStringList(joinIdList)})`
];
if (printTraceList.length > 0) {
whereParts.push(`print_trace_id IN (${buildStringList(printTraceList)})`);
}
const lookupLimit = clampLookupLimit(joinIdList.length + printTraceList.length);
const result = await client.query({
query: `SELECT * FROM ${EQUITY_PRINT_JOINS_TABLE} WHERE id IN (${buildStringList(uniqueIds)}) ORDER BY source_ts DESC, seq DESC LIMIT ${clampLookupLimit(uniqueIds.length)}`,
query: `SELECT * FROM ${EQUITY_PRINT_JOINS_TABLE} WHERE ${whereParts.join(" OR ")} ORDER BY source_ts DESC, seq DESC LIMIT ${lookupLimit}`,
format: "JSONEachRow"
});