code: func (p *Pipeline) SetTask(t *api.Task) {
  	for i := range p.checklist {
  		p.checklist[i].enabled = p.checklist[i].f.SetTask(t)
  		p.checklist[i].failureCount = 0
  	}
  }
docs: // SetTask sets up the filters to process a new task. Once this is called,
  // Process can be called repeatedly to try to assign the task various nodes.