Skip to content

Commit e33ddfb

Browse files
committed
perf(server): 等待线程时只读取待回答请求
- 通过现有投影查询过滤已经处理的请求,减少长会话等待唤醒时的读取量。 - 保持输入和审批识别逻辑,变更范围检查的 243 项测试全部通过。
1 parent 4dde201 commit e33ddfb

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

‎apps/server/src/orchestration-v2/ThreadManagementService.ts‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -946,7 +946,11 @@ const make = Effect.gen(function* () {
946946
const fields = input.terminalOnly
947947
? (["runs"] as const)
948948
: (["runs", "nodes", "runtimeRequests", "turnItems"] as const);
949-
const filter = { turnItemTypes: ["secret_request"], omitSettledLeafNodes: true } as const;
949+
const filter = {
950+
turnItemTypes: ["secret_request"],
951+
omitSettledLeafNodes: true,
952+
runtimeRequestStatuses: ["pending"],
953+
} as const;
950954
const target = yield* getProjectThreadRecords(input, fields, filter);
951955
const selectedRun =
952956
input.runId === undefined

0 commit comments

Comments
 (0)