code: func (s *storageImpl) registerTasks() {
  	// See queue.yaml for "cas-uploads" task queue definition.
  	s.tq.RegisterTask(&tasks.VerifyUpload{}, func(c context.Context, m proto.Message) error {
  		return s.verifyUploadTask(c, m.(*tasks.VerifyUpload))
  	}, "cas-uploads", nil)
  	s.tq.RegisterTask(&tasks.CleanupUpload{}, func(c context.Context, m proto.Message) error {
  		return s.cleanupUploadTask(c, m.(*tasks.CleanupUpload))
  	}, "cas-uploads", nil)
  }
docs: // registerTasks adds tasks to the tq Dispatcher.