(p *plan.Delete)
| 165 | return root, root.Add(NewUpdate(m.Ctx, p)) |
| 166 | } |
| 167 | func (m *JobExecutor) WalkDelete(p *plan.Delete) (Task, error) { |
| 168 | root := m.NewTask(p) |
| 169 | return root, root.Add(NewDelete(m.Ctx, p)) |
| 170 | } |
| 171 | func (m *JobExecutor) WalkSource(p *plan.Source) (Task, error) { |
| 172 | if len(p.Static) > 0 { |
| 173 | static := membtree.NewStaticData("static") |