Merge pull request #385 from lichess-org/fix/oom

Revert "Use all instead of compile.stream.toList"
lichess-org · Dec 4, 2024 · c790abf · c790abf
2 parents 47ea964 + eb0f977
commit c790abf
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/modules/ingestor/src/main/scala/mongo.chapter.scala b/modules/ingestor/src/main/scala/mongo.chapter.scala
@@ -110,6 +110,9 @@ object ChapterRepo:
     def byStudyIds(ids: List[String]): IO[Map[String, StudyData]] =
       coll
         .aggregateWithCodec[StudyData](Query.aggregate(ids))
-        .all
         // .flatTap(docs => Logger[IO].debug(s"Received $docs chapters"))
+        .stream
+        .compile
+        .toList
+        .flatTap(docs => Logger[IO].debug(s"Received $docs chapters"))
         .map(_.map(x => x._id -> x).toMap)