diff --git a/app/src/main/kotlin/net/primal/android/highlights/db/HighlightDao.kt b/app/src/main/kotlin/net/primal/android/highlights/db/HighlightDao.kt
index b89363d71..3789dd8fc 100644
--- a/app/src/main/kotlin/net/primal/android/highlights/db/HighlightDao.kt
+++ b/app/src/main/kotlin/net/primal/android/highlights/db/HighlightDao.kt
@@ -2,6 +2,7 @@ package net.primal.android.highlights.db
 
 import androidx.room.Dao
 import androidx.room.Query
+import androidx.room.Transaction
 import androidx.room.Upsert
 import kotlinx.coroutines.flow.Flow
 
@@ -16,6 +17,7 @@ interface HighlightDao {
     @Query("DELETE FROM HighlightData WHERE highlightId = :highlightId")
     fun deleteById(highlightId: String)
 
+    @Transaction
     @Query("SELECT * FROM HighlightData WHERE highlightId = :highlightId LIMIT 1")
     fun observeById(highlightId: String): Flow<Highlight>
 }