@@ -1238,18 +1238,18 @@ func TestTemplateInsights_Golden(t *testing.T) {
12381238templates ,users ,testData := prepareFixtureAndTestData (t ,tt .makeFixture ,tt .makeTestData )
12391239client ,events := prepare (t ,templates ,users ,testData )
12401240
1241+ // Drain two events, the first one resumes rolluper
1242+ // operation and the second one waits for the rollup
1243+ // to complete.
1244+ _ ,_ = <- events ,<- events
1245+
12411246for _ ,req := range tt .requests {
12421247req := req
12431248t .Run (req .name ,func (t * testing.T ) {
12441249t .Parallel ()
12451250
12461251ctx := testutil .Context (t ,testutil .WaitMedium )
12471252
1248- // Drain two events, the first one resumes rolluper
1249- // operation and the second one waits for the rollup
1250- // to complete.
1251- _ ,_ = <- events ,<- events
1252-
12531253report ,err := client .TemplateInsights (ctx ,req .makeRequest (templates ))
12541254require .NoError (t ,err ,"want no error getting template insights" )
12551255
@@ -2024,18 +2024,18 @@ func TestUserActivityInsights_Golden(t *testing.T) {
20242024templates ,users ,testData := prepareFixtureAndTestData (t ,tt .makeFixture ,tt .makeTestData )
20252025client ,events := prepare (t ,templates ,users ,testData )
20262026
2027+ // Drain two events, the first one resumes rolluper
2028+ // operation and the second one waits for the rollup
2029+ // to complete.
2030+ _ ,_ = <- events ,<- events
2031+
20272032for _ ,req := range tt .requests {
20282033req := req
20292034t .Run (req .name ,func (t * testing.T ) {
20302035t .Parallel ()
20312036
20322037ctx := testutil .Context (t ,testutil .WaitMedium )
20332038
2034- // Drain two events, the first one resumes rolluper
2035- // operation and the second one waits for the rollup
2036- // to complete.
2037- _ ,_ = <- events ,<- events
2038-
20392039report ,err := client .UserActivityInsights (ctx ,req .makeRequest (templates ))
20402040require .NoError (t ,err ,"want no error getting template insights" )
20412041