Method Apply

provisioner/terraform/provision.go:284–337

(
	sess *provisionersdk.Session, request *proto.ApplyRequest, canceledOrComplete <-chan struct{},
)

}

func (s *server) Apply(
	sess *provisionersdk.Session, request *proto.ApplyRequest, canceledOrComplete <-chan struct{},
) *proto.ApplyComplete {
	ctx, span := s.startTrace(sess.Context(), tracing.FuncName())
	defer span.End()
	ctx, cancel, killCtx, kill := s.setupContexts(ctx, canceledOrComplete)
	defer cancel()
	defer kill()

	e := s.executor(sess.Files, database.ProvisionerJobTimingStageApply)
	if err := e.checkMinVersion(ctx); err != nil {
		return provisionersdk.ApplyErrorf("%s", err.Error())
	}
	logTerraformEnvVars(sess)

	// Earlier in the session, Plan() will have written the state file and the plan file.
	statefilePath := sess.Files.StateFilePath()

	// Exit early if there is no state file. This is necessary to
	// avoid any cases where a workspace is "locked out" of terraform due to
	// e.g. bad template param values and cannot be deleted. This is just for
	// contingency, in the future we will try harder to prevent workspaces being
	// broken this hard.
	if request.Metadata.GetWorkspaceTransition() == proto.WorkspaceTransition_DESTROY {
		if _, err := os.Stat(statefilePath); errors.Is(err, os.ErrNotExist) {
			sess.ProvisionLog(proto.LogLevel_INFO, "The terraform state does not exist, there is nothing to do")
			return &proto.ApplyComplete{}
		}
	}

	env, err := provisionEnv(sess.Config, request.Metadata, nil, nil, nil)
	if err != nil {
		return provisionersdk.ApplyErrorf("provision env: %s", err)
	}
	env = otelEnvInject(ctx, env)
	endStage := e.timings.startStage(database.ProvisionerJobTimingStageApply)
	resp, err := e.apply(
		ctx, killCtx, env, sess,
	)
	endStage(err)
	if err != nil {
		errorMessage := err.Error()
		// Terraform can fail and apply and still need to store it's state.
		// In this case, we return Complete with an explicit error message.
		stateData, _ := os.ReadFile(statefilePath)
		return &proto.ApplyComplete{
			State:   stateData,
			Error:   errorMessage,
			Timings: e.timings.aggregate(),
		}
	}
	resp.Timings = e.timings.aggregate()
	return resp
}

func planVars(plan *proto.PlanRequest) ([]string, error) {
	vars := []string{}