logs, err := os.ReadDir(dir)
	require.NoError(t, err)
	assert.Len(t, logs, 5)
	assert.Equal(t, testLogs[0], logs[0].Name())
	assert.Equal(t, testLogs[1]+"."+timestamp, logs[1].Name())
	assert.Equal(t, testLogs[4]+compressSuffix, logs[2].Name())
	assert.Equal(t, testLogs[2]+"."+timestamp, logs[3].Name())
	assert.Equal(t, testLogs[3], logs[4].Name())
}

func TestClean(t *testing.T) {
	ctx := context.Background()

"""Merge all JUnit test.xml files in one directory into one.

Usage: squash_testlogs.py START_DIRECTORY OUTPUT_FILE

Example: squash_testlogs.py /tf/pkg/testlogs /tf/pkg/merged.xml

Recursively find all the JUnit test.xml files in one directory, and merge any
of them that contain failures into one file. The TensorFlow DevInfra team

Feng Liu <******@****.***> 1602113375 -0700

{"Action":"cont","Test":"TestTags"}
{"Action":"output","Test":"TestTags","Output":"=== CONT  TestTags\n"}
{"Action":"cont","Test":"TestVetVerbose"}
{"Action":"output","Test":"TestVetVerbose","Output":"=== CONT  TestVetVerbose\n"}
{"Action":"run","Test":"TestTags/testtag"}
{"Action":"output","Test":"TestTags/testtag","Output":"=== RUN   TestTags/testtag\n"}
{"Action":"output","Test":"TestTags/testtag","Output":"=== PAUSE TestTags/testtag\n"}

=== PAUSE TestVet
=== RUN   TestVetAsm
=== PAUSE TestVetAsm
=== RUN   TestVetDirs
=== PAUSE TestVetDirs
=== RUN   TestTags
=== PAUSE TestTags
=== RUN   TestVetVerbose
=== PAUSE TestVetVerbose
=== CONT  TestVet
=== CONT  TestTags
=== CONT  TestVetVerbose
=== RUN   TestTags/testtag
=== PAUSE TestTags/testtag
=== CONT  TestVetDirs
=== CONT  TestVetAsm
=== RUN   TestVet/0
=== PAUSE TestVet/0
=== RUN   TestVet/1

=== RUN   Test☺☹
=== PAUSE Test☺☹
=== RUN   Test☺☹Asm
=== PAUSE Test☺☹Asm
=== RUN   Test☺☹Dirs
=== PAUSE Test☺☹Dirs
=== RUN   TestTags
=== PAUSE TestTags
=== RUN   Test☺☹Verbose
=== PAUSE Test☺☹Verbose
=== CONT  Test☺☹
=== CONT  TestTags
=== CONT  Test☺☹Verbose
=== RUN   TestTags/testtag
=== PAUSE TestTags/testtag
=== CONT  Test☺☹Dirs
=== CONT  Test☺☹Asm
=== RUN   Test☺☹/0
=== PAUSE Test☺☹/0
=== RUN   Test☺☹/1

{"Action":"cont","Test":"TestTags"}
{"Action":"output","Test":"TestTags","Output":"=== CONT  TestTags\n"}
{"Action":"cont","Test":"Test☺☹Verbose"}
{"Action":"output","Test":"Test☺☹Verbose","Output":"=== CONT  Test☺☹Verbose\n"}
{"Action":"run","Test":"TestTags/testtag"}
{"Action":"output","Test":"TestTags/testtag","Output":"=== RUN   TestTags/testtag\n"}
{"Action":"output","Test":"TestTags/testtag","Output":"=== PAUSE TestTags/testtag\n"}

	close(afterSubTest)
	<-afterSecondLog // Delay the "PASS: TestInterruptor" line until after "CONT  TestLog".
}

func TestLog(t *testing.T) {
	t.Parallel()

	t.Logf("this is the first TestLog log")
	close(afterFirstLog)
	<-afterSubTest
	t.Logf("this is the second TestLog log")
	close(afterSecondLog)

func (TestDeps) ImportPath() string {
	return ImportPath
}

// testLog implements testlog.Interface, logging actions by package os.
type testLog struct {
	mu  sync.Mutex
	w   *bufio.Writer
	set bool
}

func (l *testLog) Getenv(key string) {
	l.add("getenv", key)
}

func (l *testLog) Open(name string) {
	l.add("open", name)
}

func (l *testLog) Stat(name string) {
	l.add("stat", name)
}

		podsToAssume: []*v1.Pod{testPods[0]},
		podsToAdd:    []*v1.Pod{testPods[0]},
		podsToUpdate: []*v1.Pod{testPods[0], testPods[1], testPods[0]},
		wNodeInfo: []*framework.NodeInfo{newNodeInfo(
			&framework.Resource{
				MilliCPU: 200,
				Memory:   1024,
			},
			&framework.Resource{
				MilliCPU: 200,
				Memory:   1024,
			},
			[]*v1.Pod{testPods[1]},