throttle streamer picture migration
This commit is contained in:
parent
2b4dcc7ad3
commit
0cc17d4efa
|
@ -1,5 +1,6 @@
|
||||||
package lila.streamer
|
package lila.streamer
|
||||||
|
|
||||||
|
import scala.concurrent.duration._
|
||||||
import akka.stream.scaladsl._
|
import akka.stream.scaladsl._
|
||||||
import play.api.libs.Files
|
import play.api.libs.Files
|
||||||
import play.api.mvc.MultipartFormData
|
import play.api.mvc.MultipartFormData
|
||||||
|
@ -29,6 +30,7 @@ final private class StreamerPictureMigration(
|
||||||
.sort($sort desc "liveAt")
|
.sort($sort desc "liveAt")
|
||||||
.cursor[Bdoc]()
|
.cursor[Bdoc]()
|
||||||
.documentSource()
|
.documentSource()
|
||||||
|
.throttle(20, 1 second)
|
||||||
.mapAsync(1)(migrate)
|
.mapAsync(1)(migrate)
|
||||||
.via(lila.common.LilaStream.logRate[Unit]("streamer.picfit.migration")(logger))
|
.via(lila.common.LilaStream.logRate[Unit]("streamer.picfit.migration")(logger))
|
||||||
.toMat(LilaStream.sinkCount)(Keep.right)
|
.toMat(LilaStream.sinkCount)(Keep.right)
|
||||||
|
|
Loading…
Reference in a new issue