Function finish

projects/openade-module/src/node.ts:1015–1037

(result: HeadlessHyperPlanStepResult)

    return new Promise((resolve) => {
        const finish = (result: HeadlessHyperPlanStepResult) => {
            if (settled) return
            settled = true
            void (async () => {
                await Promise.all(persistedWrites)
                const text = extractOpenADEPlanText(events, step.agent.harnessId) ?? undefined
                if (!isTerminal) {
                    await writer.updateHyperPlanSubExecution({
                        taskId,
                        eventId,
                        stepId: step.id,
                        status: result.status === "completed" ? "completed" : result.status === "stopped" ? "stopped" : "error",
                        resultText: text,
                        error: result.status === "error" ? result.error ?? "Execution failed" : undefined,
                    })
                }
                resolve({
                    ...result,
                    text: result.text ?? text,
                    sessionId: result.sessionId ?? sessionId,
                })
            })()
        }

        void agentExecutor
            .start(