( group: WorkflowGroup )
| 188 | * writes. |
| 189 | */ |
| 190 | export function buildOutputsByBlockId( |
| 191 | group: WorkflowGroup |
| 192 | ): Map<string, Array<{ path: string; columnName: string }>> { |
| 193 | const map = new Map<string, Array<{ path: string; columnName: string }>>() |
| 194 | for (const out of group.outputs) { |
| 195 | const list = map.get(out.blockId) ?? [] |
| 196 | list.push({ path: out.path, columnName: out.columnName }) |
| 197 | map.set(out.blockId, list) |
| 198 | } |
| 199 | return map |
| 200 | } |
| 201 | |
| 202 | /** Type-narrowing helper used by readers that can't assume `executions` is set. */ |
| 203 | export function readExecutions( |
no test coverage detected