(taskId: string)
| 274 | * Useful before reading output to ensure all data is flushed. |
| 275 | */ |
| 276 | export async function flushTaskOutput(taskId: string): Promise<void> { |
| 277 | const output = outputs.get(taskId) |
| 278 | if (output) { |
| 279 | await output.flush() |
| 280 | } |
| 281 | } |
| 282 | |
| 283 | /** |
| 284 | * Evict a task's DiskTaskOutput from the in-memory map after flushing. |