(request)
| 845 | }, |
| 846 | |
| 847 | async addHyperPlanSubExecution(request) { |
| 848 | const taskDoc = await loadDoc(storage, `code:task:${request.taskId}`) |
| 849 | |
| 850 | try { |
| 851 | const meta = taskDoc.getMap("task:meta") |
| 852 | assertTaskMeta(meta, request.taskId) |
| 853 | const event = getActionEventMap(taskDoc, request.taskId, request.eventId) |
| 854 | |
| 855 | taskDoc.transact(() => { |
| 856 | const subExecutions = ensureYArray(event, "hyperplanSubExecutions") |
| 857 | if (getHyperPlanSubExecutionMap(event, request.subExecution.stepId)) return |
| 858 | const converted = toYValue(request.subExecution) |
| 859 | if (converted !== undefined) subExecutions.push([converted]) |
| 860 | }) |
| 861 | await saveDoc(storage, `code:task:${request.taskId}`, taskDoc) |
| 862 | } finally { |
| 863 | taskDoc.destroy() |
| 864 | } |
| 865 | }, |
| 866 | |
| 867 | async appendHyperPlanSubExecutionStreamEvent(request) { |
| 868 | const taskDoc = await loadDoc(storage, `code:task:${request.taskId}`) |
nothing calls this directly
no test coverage detected