Flush fakeintake payloads before testing IO collection

DataDog · Mar 7, 2025 · d2f590e · d2f590e
1 parent 6bcac34
commit d2f590e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/test/new-e2e/tests/process/windows_test.go b/test/new-e2e/tests/process/windows_test.go
@@ -122,6 +122,9 @@ func (s *windowsTestSuite) TestProcessCheckIO() {
 		awshost.WithAgentOptions(agentparams.WithAgentConfig(processCheckConfigStr), agentparams.WithSystemProbeConfig(systemProbeConfigStr)),
 	))
 
+	// Flush fake intake to remove payloads that won't have IO stats
+	s.Env().FakeIntake.Client().FlushServerAndResetAggregators()
+
 	assert.EventuallyWithT(t, func(collect *assert.CollectT) {
 		assertRunningChecks(collect, s.Env().Agent.Client, []string{"process", "rtprocess"}, true)
 	}, 1*time.Minute, 5*time.Second)