diff --git a/internal/app/machined/pkg/runtime/v1alpha1/v1alpha1_events_test.go b/internal/app/machined/pkg/runtime/v1alpha1/v1alpha1_events_test.go
index c3a513637..e87dcaa5b 100644
--- a/internal/app/machined/pkg/runtime/v1alpha1/v1alpha1_events_test.go
+++ b/internal/app/machined/pkg/runtime/v1alpha1/v1alpha1_events_test.go
@@ -79,6 +79,8 @@ func TestEvents_Publish(t *testing.T) {
 				if err := e.Watch(func(events <-chan runtime.Event) {
 					defer wg.Done()
 
+					l := rate.NewLimiter(500, tt.cap*8/10)
+
 					for j := 0; j < tt.messages; j++ {
 						event, ok := <-events
 
@@ -97,6 +99,8 @@ func TestEvents_Publish(t *testing.T) {
 						}
 
 						atomic.AddUint32(&got, 1)
+
+						_ = l.Wait(context.Background()) //nolint: errcheck
 					}
 				}); err != nil {
 					t.Errorf("Watch error %s", err)