@@ -33,16 +33,12 @@ describe("runtime TaskFlow", () => {
3333stateJson: { lane: "inbox" },
3434});
353536-expect(created).toMatchObject({
37-syncMode: "managed",
38-ownerKey: "agent:main:main",
39-controllerId: "tests/runtime-taskflow",
40-requesterOrigin: {
41-channel: "telegram",
42-to: "telegram:123",
43-},
44-goal: "Triage inbox",
45-});
36+expect(created.syncMode).toBe("managed");
37+expect(created.ownerKey).toBe("agent:main:main");
38+expect(created.controllerId).toBe("tests/runtime-taskflow");
39+expect(created.requesterOrigin?.channel).toBe("telegram");
40+expect(created.requesterOrigin?.to).toBe("telegram:123");
41+expect(created.goal).toBe("Triage inbox");
4642expect(taskFlow.get(created.flowId)?.flowId).toBe(created.flowId);
4743expect(taskFlow.findLatest()?.flowId).toBe(created.flowId);
4844expect(taskFlow.resolve("agent:main:main")?.flowId).toBe(created.flowId);
@@ -64,11 +60,9 @@ describe("runtime TaskFlow", () => {
6460goal: "Review queue",
6561});
666267-expect(created.requesterOrigin).toMatchObject({
68-channel: "discord",
69-to: "channel:123",
70-threadId: "thread:456",
71-});
63+expect(created.requesterOrigin?.channel).toBe("discord");
64+expect(created.requesterOrigin?.to).toBe("channel:123");
65+expect(created.requesterOrigin?.threadId).toBe("thread:456");
7266});
73677468it("rejects tool contexts without a bound session key", () => {
@@ -109,30 +103,25 @@ describe("runtime TaskFlow", () => {
109103lastEventAt: 10,
110104});
111105112-expect(child).toMatchObject({
113-created: true,
114-flow: expect.objectContaining({
115-flowId: created.flowId,
116-}),
117-task: expect.objectContaining({
118-parentFlowId: created.flowId,
119-ownerKey: "agent:main:main",
120-runId: "runtime-taskflow-child",
121-}),
122-});
106+expect(child.created).toBe(true);
123107if (!child.created) {
124108throw new Error("expected child task creation to succeed");
125109}
126-expect(getTaskById(child.task.taskId)).toMatchObject({
127-parentFlowId: created.flowId,
128-ownerKey: "agent:main:main",
129-});
130-expect(getTaskFlowById(created.flowId)).toMatchObject({
131-flowId: created.flowId,
132-});
133-expect(ownerTaskFlow.getTaskSummary(created.flowId)).toMatchObject({
134-total: 1,
135-active: 1,
136-});
110+expect(child.flow.flowId).toBe(created.flowId);
111+expect(child.task.parentFlowId).toBe(created.flowId);
112+expect(child.task.ownerKey).toBe("agent:main:main");
113+expect(child.task.runId).toBe("runtime-taskflow-child");
114+115+const storedTask = getTaskById(child.task.taskId);
116+expect(storedTask?.parentFlowId).toBe(created.flowId);
117+expect(storedTask?.ownerKey).toBe("agent:main:main");
118+expect(getTaskFlowById(created.flowId)?.flowId).toBe(created.flowId);
119+const summary = ownerTaskFlow.getTaskSummary(created.flowId);
120+expect(summary).toBeDefined();
121+if (!summary) {
122+throw new Error("expected task summary for created flow");
123+}
124+expect(summary.total).toBe(1);
125+expect(summary.active).toBe(1);
137126});
138127});
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。