diff --git a/services/activitylog/pkg/service/service.go b/services/activitylog/pkg/service/service.go
index b9488a84ba..2183bdb24a 100644
--- a/services/activitylog/pkg/service/service.go
+++ b/services/activitylog/pkg/service/service.go
@@ -416,6 +416,7 @@ func (a *ActivitylogService) activities(rid *provider.ResourceId) ([]RawActivity
 	if err != nil {
 		return nil, err
 	}
+	defer watcher.Stop()
 
 	var activities []RawActivity
 	for update := range watcher.Updates() {