Method init

provisioner/terraform/executor.go:218–279

(ctx, killCtx context.Context, logr logSink)

}

func (e *executor) init(ctx, killCtx context.Context, logr logSink) error {
	ctx, span := e.server.startTrace(ctx, tracing.FuncName())
	defer span.End()

	e.mut.Lock()
	defer e.mut.Unlock()

	// Record lock file checksum before init
	lockFilePath := e.files.TerraformLockFile()
	preInitChecksum := checksumFileCRC32(ctx, e.logger, lockFilePath)

	outWriter, doneOut := e.provisionLogWriter(logr)
	errWriter, doneErr := logWriter(logr, proto.LogLevel_ERROR)
	defer func() {
		_ = outWriter.Close()
		_ = errWriter.Close()
		<-doneOut
		<-doneErr
	}()

	// As a special case, we want to look for the error "text file busy" in the stderr output of
	// the init command, so we also take a copy of the stderr into an in memory buffer.
	errBuf := newBufferedWriteCloser(errWriter)

	args := []string{
		"init",
		"-no-color",
		"-input=false",
	}

	ver, err := e.version(ctx)
	if err != nil {
		return xerrors.Errorf("extract version: %w", err)
	}
	if ver.GreaterThanOrEqual(version190) {
		// Added in v1.9.0:
		args = append(args, "-json")
	}

	err = e.execWriteOutput(ctx, killCtx, args, e.basicEnv(), outWriter, errBuf)
	var exitErr *exec.ExitError
	if xerrors.As(err, &exitErr) {
		if bytes.Contains(errBuf.b.Bytes(), []byte("text file busy")) {
			return &textFileBusyError{exitErr: exitErr, stderr: errBuf.b.String()}
		}
	}
	if err != nil {
		return err
	}

	// Check if lock file was modified
	postInitChecksum := checksumFileCRC32(ctx, e.logger, lockFilePath)
	if preInitChecksum != 0 && postInitChecksum != 0 && preInitChecksum != postInitChecksum {
		e.logger.Warn(ctx, fmt.Sprintf(".terraform.lock.hcl was modified during init. This means provider hashes "+
			"are missing for the current platform (%s_%s). Update the lock file with:\n\n"+
			"  terraform providers lock -platform=linux_amd64 -platform=linux_arm64 "+
			"-platform=darwin_amd64 -platform=darwin_arm64 -platform=windows_amd64\n",
			runtime.GOOS, runtime.GOARCH),