code: func (r *Orchestrator) initTasks(ctx context.Context, readTx store.ReadTx) error {
  	return taskinit.CheckTasks(ctx, r.store, readTx, r, r.restarts)
  }
docs: // This file provides task-level orchestration. It observes changes to task
  // and node state and kills/recreates tasks if necessary. This is distinct from
  // service-level reconciliation, which observes changes to services and creates
  // and/or kills tasks to match the service definition.