func()

in pkg/clusters/nodepools.go [56:76]

• 16 lines of code
• 4 McCabe index (conditional complexity)

func (m *nodePoolMigrator) Complete(ctx context.Context) error {
	var err error
	m.upgradeRequired, err = m.isUpgradeRequired(ctx)
	if err != nil {
		return fmt.Errorf("unable to verify state for NodePool %s: %w", m.ResourcePath(), err)
	}

	def, valid := getVersions(m.serverConfig, m.releaseChannel, Node)
	if m.opts.DesiredNodeVersion == DefaultVersion {
		// Node pool upgrade using default alias selects the control plane version.
		// See: https://cloud.google.com/kubernetes-engine/docs/reference/rest/v1/projects.zones.clusters.nodePools/update#request-body
		def = m.resolvedDesiredControlPlaneVersion
	}

	m.resolvedDesiredNodeVersion, err = resolveVersion(m.opts.DesiredNodeVersion, def, valid)
	if err != nil {
		return m.wrap(err, "Complete")
	}

	return nil
}