diff --git a/go/src/v.io/x/sensorlog/internal/client/list.go b/go/src/v.io/x/sensorlog/internal/client/list.go
index cab7e19..2cc66a3 100644
--- a/go/src/v.io/x/sensorlog/internal/client/list.go
+++ b/go/src/v.io/x/sensorlog/internal/client/list.go
@@ -13,6 +13,7 @@
 	"v.io/v23/context"
 	wire "v.io/v23/services/syncbase"
 	"v.io/v23/syncbase"
+	"v.io/v23/syncbase/util"
 	"v.io/v23/verror"
 	"v.io/x/sensorlog/internal/sbmodel"
 	"v.io/x/sensorlog/internal/sbmodel/keyutil"
@@ -65,10 +66,9 @@
 
 	// Watch for DataPoints, existing followed by new.
 	// TODO(ivanpi): Check if stream exists.
-	ws, err := db.Watch(ctx, dataCollectionId, dataPrefix, nil)
-	if err != nil {
-		return err
-	}
+	ws := db.Watch(ctx, nil, []wire.CollectionRowPattern{
+		util.RowPrefixPattern(dataCollectionId, dataPrefix),
+	})
 	defer ws.Cancel()
 
 	trans := make([]*dataPoint, 0, 16)
diff --git a/go/src/v.io/x/sensorlog/internal/measure/watcher.go b/go/src/v.io/x/sensorlog/internal/measure/watcher.go
index 284a41c..f209940 100644
--- a/go/src/v.io/x/sensorlog/internal/measure/watcher.go
+++ b/go/src/v.io/x/sensorlog/internal/measure/watcher.go
@@ -10,7 +10,9 @@
 	"fmt"
 
 	"v.io/v23/context"
+	wire "v.io/v23/services/syncbase"
 	"v.io/v23/syncbase"
+	"v.io/v23/syncbase/util"
 	"v.io/x/sensorlog/internal/sbmodel"
 	"v.io/x/sensorlog/internal/sbmodel/keyutil"
 )
@@ -31,10 +33,9 @@
 	watchPrefix := keyutil.Join(devId, "")
 
 	// Watch for StreamDef changes and register samplers as needed.
-	ws, err := db.Watch(ctx, collectionId, watchPrefix, nil)
-	if err != nil {
-		return err
-	}
+	ws := db.Watch(ctx, nil, []wire.CollectionRowPattern{
+		util.RowPrefixPattern(collectionId, watchPrefix),
+	})
 	defer ws.Cancel()
 
 	for ws.Advance() {