code: func (impl *repoImpl) registerTasks() {
  	// See queue.yaml for "run-processors" task queue definition.
  	impl.tq.RegisterTask(&tasks.RunProcessors{}, func(c context.Context, m proto.Message) error {
  		return impl.runProcessorsTask(c, m.(*tasks.RunProcessors))
  	}, "run-processors", nil)
  }
docs: // registerTasks adds tasks to the tq Dispatcher.