@IntegrationTestTimeout(120)
class WorkerExecutorErrorHandlingIntegrationTest extends AbstractWorkerExecutorIntegrationTest {
    WorkerExecutorFixture.WorkActionClass actionThatFailsInstantiation
    WorkerExecutorFixture.WorkActionClass actionThatThrowsUnserializableMemberException

    def setup() {
        actionThatFailsInstantiation = fixture.getWorkActionThatCreatesFiles("ActionThatFailsInstantiation")

            }
        """
    }

    WorkActionClass workActionClass(String name, String packageName, WorkParameterClass parameterClass) {
        return new WorkActionClass(name, packageName, parameterClass)
    }

    WorkParameterClass workParameterClass(String name, String packageName) {
        return new WorkParameterClass(name, packageName)
    }

    WorkActionClass getWorkActionThatCreatesFiles(String name) {

                isolationMode = 'processIsolation'
                workActionClass = ${fixture.workActionThatCreatesFiles.name}.class
            }
        """

        when:
        succeeds("runInDaemon")

        then:
        assertWorkerExecuted("runInDaemon")
    }

    WorkerExecutorFixture.WorkActionClass getWorkActionThatVerifiesExecutable(Jvm differentJvm) {

                doLast { submitWorkItem("taskAction1", workActionClass) { isolationMode = 'processIsolation' } }
                doLast { submitWorkItem("taskAction2", workActionClass) { isolationMode = 'classLoaderIsolation' } }
                doLast { submitWorkItem("taskAction3", workActionClass) { isolationMode = 'processIsolation' } }
                doLast { submitWorkItem("taskAction4", workActionClass) { isolationMode = 'processIsolation' } }

    }
    private <T extends WorkParameters> AsyncWorkCompletion submitWork(Class<? extends WorkAction<T>> workActionClass, Action<? super T> parameterAction, WorkerSpec workerSpec, WorkerFactory workerFactory) {
        Class<T> parameterType = isolationScheme.parameterTypeFor(workActionClass);
        T parameters = (parameterType == null) ? null : instantiator.newInstance(parameterType);
        if (parameters != null) {

package org.gradle.workers.internal

import org.gradle.workers.fixtures.WorkerExecutorFixture.WorkActionClass
import spock.lang.Timeout

import static org.gradle.workers.fixtures.WorkerExecutorFixture.ISOLATION_MODES

@Timeout(120)
class WorkerExecutorLoggingIntegrationTest extends AbstractWorkerExecutorIntegrationTest {
    WorkActionClass executionWithLogging

    def setup() {

            task runInDaemon(type: WorkerTask) {
                isolationMode = 'processIsolation'
                workActionClass = BlockingWorkAction.class
            }

            task startNewDaemon(type: WorkerTask) {
                isolationMode = 'processIsolation'
                workActionClass = BlockingWorkAction.class
            }

            task runAllDaemons {

        then:
        result.groupedOutput.task(':runInWorker').output.contains("Hello World")
    }

    WorkerExecutorFixture.WorkActionClass getFirstLevelExecution(String nestedIsolationMode) {
        def workerClass = fixture.workActionClass("FirstLevelExecution", "org.gradle.test", nestingParameterType)
        workerClass.imports += [WorkerExecutor.name, Internal.name]
        workerClass.extraFields = """

            import org.gradle.test.TestWork
            ${buildFile.text}
        """
    }

    void withRunnableClassThatFails() {
        workActionClass.text = workActionClass.text.replace('// DO NOTHING', 'throw new IllegalStateException("something went horribly wrong");')
    }

        }

        fixture.withWorkActionClassInBuildScript()
        buildFile << """
            task runInWorker(type: WorkerTask) {
                isolationMode = 'processIsolation'
                workActionClass = ${workActionThatProducesLotsOfOutput.name}.class
            }
        """
    }

    @Issue("https://github.com/gradle/gradle/issues/10122")
    def "can log many messages from action in a worker daemon"() {