Skip to content

Commit

Permalink
fix copied text
Browse files Browse the repository at this point in the history
  • Loading branch information
ornicar committed Jan 22, 2025
1 parent c726d50 commit a464f16
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion modules/ingestor/src/main/scala/mongo.forum.scala
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ object ForumRepo:
val filter = range(F.createdAt)(since, until.some)
.or(range(F.updatedAt)(since, until.some))
.or(range(F.erasedAt)(since, until.some))
fs2.Stream.eval(info"Fetching teams from $since to $until") *>
fs2.Stream.eval(info"Fetching forum posts from $since to $until") *>
posts
.find(filter)
.projection(postProjection)
Expand Down
2 changes: 1 addition & 1 deletion modules/ingestor/src/main/scala/mongo.game.scala
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ object GameRepo:
def fetch(since: Instant, until: Instant): fs2.Stream[IO, Result[GameSource]] =
val filter = range(F.createdAt)(since, until.some)
.or(range(F.updatedAt)(since, until.some))
fs2.Stream.eval(info"Fetching teams from $since to $until") *>
fs2.Stream.eval(info"Fetching games from $since to $until") *>
games
.find(filter.and(gameFilter))
// .projection(postProjection)
Expand Down

0 comments on commit a464f16

Please sign in to comment.