/**
     * @return output that would appear in the log file
     */
    def logOutput() {
        TextUtil.normaliseLineSeparators(outputFile.text)
    }

    def "logs start of overall operation"() {
        when:
        log.start()
        then:
        logOutput() == """See $pathToLogStr for all output for <testTask>.
"""
        cleanup:
        log.done()
    }

                .setStandardOutput(stdout)
                .setStandardError(stderr)
                .get()
        }

        then:
        project != null
        def logOutput = stdout.toString()
        !logOutput.contains(waitingMessage)
        !logOutput.contains(exitingContinuousBuildNoInputsDetectedMessage)
    }

    private String getExitingContinuousBuildNoInputsDetectedMessage() {
        return usesNativeWatchers()

    @Rule public final TestResources resources = new TestResources(testDirectoryProvider)
    @Rule public final Sample sampleResources = new Sample(testDirectoryProvider)

    final LogOutput logOutput = createLogOutput()

    final LogOutput customLoggerOutput = createLogOutput().tap {
        quiet(
            'init callback quiet out')
        lifecycle(
            'LOGGER: evaluating :',

        def jdk8 = temporaryFolder.createFile("not-a-directory")
        def logOutput = "Path for java installation '${jdk8}' (testSource) points to a file, not a directory"
        when:
        def registry = createRegistry([jdk8])
        def installations = registry.listInstallations()

        then:
        installations.isEmpty()
        1 * logger.log(_, logOutput)

        when:

            Path path = entry.getKey();
            showIndividualChange(logger, path, type);
        }
        if (moreChangesCount > 0) {
            logOutput(logger, "and some more changes");
        }
        if (errorWhenWatching) {
            logOutput(logger, "Error when watching files - triggering a rebuild");
        }
    }

	}
}

func printLog(ms diag.Messages, colorize bool) string {
	logOutput := make([]string, 0, len(ms))
	for _, m := range ms {
		logOutput = append(logOutput, render(m, colorize))
	}
	return strings.Join(logOutput, "\n")
}

func printJSON(ms diag.Messages) (string, error) {
	jsonOutput, err := json.MarshalIndent(ms, "", "\t")
	return string(jsonOutput), err

`

	g.Expect(output).To(Equal(expectedOutput))
}

func TestFormatter_PrintEmpty(t *testing.T) {
	g := NewWithT(t)

	msgs := diag.Messages{}

	logOutput, _ := Print(msgs, LogFormat, false)
	g.Expect(logOutput).To(Equal(""))

	jsonOutput, _ := Print(msgs, JSONFormat, false)
	g.Expect(jsonOutput).To(Equal("[]"))

	yamlOutput, _ := Print(msgs, YAMLFormat, false)

		t.Errorf("client read all successfully; want some error")
	}
	logOutput := func() string {
		errorLog.Lock()
		defer errorLog.Unlock()
		return errorLog.String()
	}
	wantStackLogged := panicValue != nil && panicValue != ErrAbortHandler

	waitCondition(t, 10*time.Millisecond, func(d time.Duration) bool {
		gotLog := logOutput()
		if !wantStackLogged {
			if gotLog == "" {
				return true
			}

                    "--expendable-pods-priority-cutoff=-10",
                    {{params}}
                ],
                "env": [
                    {
                        "name": "LOG_OUTPUT",
                        "value": "/var/log/cluster-autoscaler.log"
                    }
                ],
                "resources": {
                    "requests": {
                        "cpu": "10m",