diff --git a/syncapi/storage/postgres/account_data_table.go b/syncapi/storage/postgres/account_data_table.go
index 22bb4d7fa..0a7146913 100644
--- a/syncapi/storage/postgres/account_data_table.go
+++ b/syncapi/storage/postgres/account_data_table.go
@@ -118,7 +118,7 @@ func (s *accountDataStatements) SelectAccountDataInRange(
 
 	var dataType string
 	var roomID string
-	var id types.StreamPosition
+	id := r.From
 
 	for rows.Next() {
 		if err = rows.Scan(&id, &roomID, &dataType); err != nil {
diff --git a/syncapi/storage/sqlite3/account_data_table.go b/syncapi/storage/sqlite3/account_data_table.go
index e0d97ec32..d84159ac8 100644
--- a/syncapi/storage/sqlite3/account_data_table.go
+++ b/syncapi/storage/sqlite3/account_data_table.go
@@ -114,7 +114,7 @@ func (s *accountDataStatements) SelectAccountDataInRange(
 
 	var dataType string
 	var roomID string
-	var id types.StreamPosition
+	id := r.From
 
 	for rows.Next() {
 		if err = rows.Scan(&id, &roomID, &dataType); err != nil {