diff --git a/veilid-core/src/storage_manager/record_store/mod.rs b/veilid-core/src/storage_manager/record_store/mod.rs
index 3e30cced..f094f0ec 100644
--- a/veilid-core/src/storage_manager/record_store/mod.rs
+++ b/veilid-core/src/storage_manager/record_store/mod.rs
@@ -1037,7 +1037,7 @@ where
         let Some(member_check) = self.with_record(key, |record| {
             let schema = record.schema();
             let owner = *record.owner();
-            Box::new(move |watcher| owner == params.watcher || schema.is_member(&watcher))
+            Box::new(move |watcher| owner == watcher || schema.is_member(&watcher))
         }) else {
             // Record not found
             return Ok(WatchResult::Rejected);