From ba2c4e075a07bc5343699d5371cbd8a6f360f534 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Fri, 8 May 2026 18:10:33 +0100 Subject: [PATCH] test: require taskflow child task --- src/tasks/task-executor.test.ts | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/src/tasks/task-executor.test.ts b/src/tasks/task-executor.test.ts index 4ac9b1f745d..91b1e419c43 100644 --- a/src/tasks/task-executor.test.ts +++ b/src/tasks/task-executor.test.ts @@ -111,6 +111,15 @@ function expectParentFlowId(task: { parentFlowId?: string }): string { return task.parentFlowId; } +function requireCreatedFlowTask( + result: ReturnType, +): NonNullable["task"]> { + if (!result.task) { + throw new Error("Expected TaskFlow child task to be created"); + } + return result.task; +} + function createRunningAcpChildTaskRun( overrides: Partial[0]> = {}, ) { @@ -497,7 +506,8 @@ describe("task-executor", () => { runId: "run-flow-child", }), }); - expect(getTaskById(created.task!.taskId)).toMatchObject({ + const createdTask = requireCreatedFlowTask(created); + expect(getTaskById(createdTask.taskId)).toMatchObject({ parentFlowId: flow.flowId, ownerKey: "agent:main:main", childSessionKey: "agent:codex:acp:child", @@ -548,7 +558,7 @@ describe("task-executor", () => { controllerId: "tests/managed-flow", goal: "Long running batch", }); - const child = runTaskInFlow({ + const created = runTaskInFlow({ flowId: flow.flowId, runtime: "acp", childSessionKey: "agent:codex:acp:child", @@ -557,7 +567,8 @@ describe("task-executor", () => { status: "running", startedAt: 10, lastEventAt: 10, - }).task!; + }); + const child = requireCreatedFlowTask(created); const cancelled = await cancelFlowById({ cfg: {} as never,