(p *plan.Upsert)
| 153 | return root, m.WalkChildren(p, root) |
| 154 | } |
| 155 | func (m *JobExecutor) WalkUpsert(p *plan.Upsert) (Task, error) { |
| 156 | root := m.NewTask(p) |
| 157 | return root, root.Add(NewUpsert(m.Ctx, p)) |
| 158 | } |
| 159 | func (m *JobExecutor) WalkInsert(p *plan.Insert) (Task, error) { |
| 160 | root := m.NewTask(p) |
| 161 | return root, root.Add(NewInsert(m.Ctx, p)) |