anchor.diff:  					clusterNodePoolsUpdateCall.Header().Add("X-Goog-User-Project", nodePoolInfo.project)
   				}
   				op, err := clusterNodePoolsUpdateCall.Do()
  -					
  +
   				if err != nil {
   					return err
   				}
  
positive.code: 	timeout := d.Timeout(schema.TimeoutCreate)
  	startTime := time.Now()
  
  	// Set the ID before we attempt to create - that way, if we receive an error but
  	// the resource is created anyway, it will be refreshed on the next call to
  	// apply.
  	d.SetId(fmt.Sprintf("projects/%s/locations/%s/clusters/%s/nodePools/%s", nodePoolInfo.project, nodePoolInfo.location, nodePoolInfo.cluster, nodePool.Name))
  
  	var operation *containerBeta.Operation
  	err = resource.Retry(timeout, func() *resource.RetryError {
  
negative.code: 		return err
  	}
  	d.Partial(false)
  
  	//Check cluster is in running state
  	_, err = containerClusterAwaitRestingState(config, nodePoolInfo.project, nodePoolInfo.location, nodePoolInfo.cluster, userAgent, d.Timeout(schema.TimeoutCreate))
  	if err != nil {
  