if err != nil {
		return fmt.Errorf("couldn't get node to daemon pod mapping for daemon set %q: %v", ds.Name, err)
	}

	toKeep := int(*ds.Spec.RevisionHistoryLimit)
	toKill := len(old) - toKeep
	if toKill <= 0 {
		return nil
	}

	// Find all hashes of live pods
	liveHashes := make(map[string]bool)
	for _, pods := range nodesToDaemonPods {
		for _, pod := range pods {

        File f = Paths.get(parent.absolutePath, "${className}.java").toFile()
        parent.mkdirs()
        f.text = body
        return [f]
    }

    List<File> toModuleSourceFile(String body) {
        def className = "module-info"
        File parent = Paths.get(sourceFolder.absolutePath, "src", "main", "java").toFile()

                @OutputDirectory
                Path outputDir

                @TaskAction
                def go() {
                    outputFile.toFile().text = inputFile.toFile().text
                    inputDir.toFile().listFiles().each { f -> outputDir.resolve(f.name).toFile().text = f.text }
                }
            }

            task transform(type: TransformTask) {
                inputFile = file("file1.txt").toPath()

    public void cancel() {
        List<Runnable> toCall = new ArrayList<Runnable>();
        synchronized (lock) {
            if (cancelled) {
                return;
            }
            cancelled = true;
            toCall.addAll(callbacks);
            callbacks.clear();
        }

        List<Throwable> failures = new ArrayList<Throwable>();
        for (Runnable callback : toCall) {
            try {

			src = strings.Replace(src, "TWOS", "2"+strings.Repeat(", 2", i-1), -1)
			fmt.Print(src)
			tocall = append(tocall, fmt.Sprintf("CheckEq%d_%s", i, strings.Title(typ)))
		}
	}
	fmt.Println("func main() {")
	for _, fun := range tocall {
		fmt.Printf("\t%s()\n", fun)
		fmt.Printf("\t%sExtraVar()\n", fun)
	}
	fmt.Println("}")

                }
            });

            t.transform(project, systemSessionMock, beforePomFile, tempFile);
        }
        XmlAssert.assertThat(afterPomFile.toFile()).and(tempFile.toFile()).areIdentical();
    }

    @Test
    void transformJarConsumerPom() throws Exception {
        RepositorySystemSession systemSessionMock = Mockito.mock(RepositorySystemSession.class);

        this.tempDirFile = tempDirPath.toFile();

        this.missingPath = tempDirPath.resolve("aaa-missing/bbb-missing/ccc-missing/ddd-missing/missing.txt");
        this.missingFile = missingPath.toFile();
        mkdirs(missingPath.getParent());

        this.existingPath = tempDirPath.resolve("aaa/bbb/ccc/ddd/missing.txt");
        this.existingFile = existingPath.toFile();
        mkdirs(existingPath.getParent());

        def fileName = "file.txt"

        when:
        serializer.write(encoder, value)

        then:
        _ * value.getCachedFile() >> commonPath.resolve(fileName).toFile()

        1 * encoder.writeString(fileName)
    }

    def "value serializer can expand relative path"() {
        given:

        final File file = new File("Program Files/hoge.txt");
        final URL url = file.toURI().toURL();
        assertEquals(file.getAbsoluteFile(), URLUtil.toFile(url));
        assertEquals(file.getAbsoluteFile(), URLUtil.toFile(new URL("file:Program%20Files/hoge.txt")));
    }

    @Deprecated
    @Override
    public File locatePom(File projectDirectory) {
        Path path = locatePom(projectDirectory != null ? projectDirectory.toPath() : null);
        return path != null ? path.toFile() : null;
    }

    @Override
    public Path locatePom(Path projectDirectory) {
        return projectDirectory != null ? projectDirectory : Paths.get(System.getProperty("user.dir"));
    }

    @Deprecated