(nodeID int)
| 60 | } |
| 61 | |
| 62 | func (pc *reconciliationContext) get(nodeID int) operationResult { |
| 63 | pc.mu.Lock() |
| 64 | defer pc.mu.Unlock() |
| 65 | return pc.results[nodeID] |
| 66 | } |
| 67 | |
| 68 | // executePlan walks the plan DAG, executing nodes in parallel where possible |
| 69 | // while respecting dependency edges. It emits progress events and handles |
no test coverage detected