(plan Plan)
| 112 | } |
| 113 | |
| 114 | func newNoopAttempt(plan Plan) PlanAttempt { |
| 115 | return PlanAttempt{ |
| 116 | state: &planAttemptState{ |
| 117 | plan: plan, |
| 118 | }, |
| 119 | } |
| 120 | } |
| 121 | |
| 122 | func (e *Engine) PreparePlan(reader metrix.Reader) (PlanAttempt, error) { |
| 123 | plan, materialized, epoch, commitSeq, attemptID, reserved, err := e.preparePlan(reader) |
no outgoing calls
no test coverage detected
searching dependent graphs…