diff --git a/tests/integration_tests/integration_test.go b/tests/integration_tests/integration_test.go
index db1f3a54..c5dc49e9 100644
--- a/tests/integration_tests/integration_test.go
+++ b/tests/integration_tests/integration_test.go
@@ -1365,6 +1365,8 @@ func (s *IntegrationTestSuite) TestDownsamplePropagation() {
 		wantAll:    false,
 	}}
 
+	env.WaitIdle()
+
 	for _, tc := range cases {
 		opts := []setup.SearchOption{setup.NoFetch(), setup.WithTotal(true)}
 		if tc.downsample != nil {