WorkerExecutorFixture.WorkActionClass parallelWorkAction

    def setup() {
        blockingHttpServer.start()

        parallelParameterType = fixture.workParameterClass("ParallelParameter", "org.gradle.test").withFields([
                "itemName": "String",
                "shouldFail": "Boolean"
        ])

    def buildOperations = new BuildOperationsFixture(executer, temporaryFolder)
    WorkerExecutorFixture.WorkParameterClass parallelParameterType
    WorkerExecutorFixture.WorkActionClass parallelWorkAction


    def setup() {
        blockingHttpServer.start()

        buildFile << """
            task slowTask {
                doLast {

        buildFile << """
            task runInWorker(type: WorkerTask) {
                isolationMode = 'processIsolation'
                additionalForkOptions = { jvmArgs('--not-a-real-argument') }
                workActionClass = ${workAction.name}.class
            }
        """
    }

    def "worker startup failure messages are associated with the task that starts it"() {

     * will be thrown from {@link #await()} or from the surrounding task action if {@link #await()} is not used.
     */
    <T extends WorkParameters> void submit(Class<? extends WorkAction<T>> workActionClass, Action<? super T> parameterAction);

    /**
     * Blocks until all work associated with this queue is complete.  Note that when using this method inside

                def projectCounter = i
                def runInWorker = tasks.register("runInWorker" + i, WorkerTask) {
                    isolationMode = 'processIsolation'
                    workActionClass = AlternateWorkAction.class
                    additionalForkOptions = {
                        jvmArgs += ['-DprojectCounter=' + projectCounter, '-DbuildCounter=' + buildCounter]
                    }
                }

    }

    void newSnapshot() {
        logSnapshot = daemons.daemon.log
    }

    String sinceSnapshot() {
        return daemons.daemon.log - logSnapshot
    }

    WorkerExecutorFixture.WorkActionClass getWorkerExecutorThatCanFailUnexpectedly() {
        def executionClass = fixture.workActionThatCreatesFiles
        executionClass.action += """
            if (getParameters().getFiles().contains("poisonPill")) {