diff --git a/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/EpisodeDao.kt b/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/EpisodeDao.kt
index 40da3f2ca..7e823e222 100644
--- a/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/EpisodeDao.kt
+++ b/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/EpisodeDao.kt
@@ -32,6 +32,7 @@ import kotlinx.coroutines.flow.Flow
  */
 @Dao
 interface EpisodeDao {
+    @Transaction
     @Query(value = "SELECT * FROM episodes")
     fun getEpisodesStream(): Flow<List<PopulatedEpisode>>
 
diff --git a/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/NewsResourceDao.kt b/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/NewsResourceDao.kt
index f03b1704d..8200712bc 100644
--- a/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/NewsResourceDao.kt
+++ b/core-database/src/main/java/com/google/samples/apps/nowinandroid/core/database/dao/NewsResourceDao.kt
@@ -34,6 +34,7 @@ import kotlinx.coroutines.flow.Flow
  */
 @Dao
 interface NewsResourceDao {
+    @Transaction
     @Query(
         value = """
             SELECT * FROM news_resources
@@ -42,6 +43,7 @@ interface NewsResourceDao {
     )
     fun getNewsResourcesStream(): Flow<List<PopulatedNewsResource>>
 
+    @Transaction
     @Query(
         value = """
             SELECT * FROM news_resources