diff --git a/build.sbt b/build.sbt index de72375a6..dc10896d5 100644 --- a/build.sbt +++ b/build.sbt @@ -1,7 +1,7 @@ val devMode = settingKey[Boolean]("Some build optimization are applied in devMode.") val writeClasspath = taskKey[File]("Write the project classpath to a file.") -val VERSION = "0.5.0" +val VERSION = "0.5.1" lazy val catsCore = "1.5.0" lazy val circe = "0.10.1" diff --git a/core/src/main/scala/com/criteo/cuttle/Utils.scala b/core/src/main/scala/com/criteo/cuttle/Utils.scala index 6ce738aaa..b31d3698f 100644 --- a/core/src/main/scala/com/criteo/cuttle/Utils.scala +++ b/core/src/main/scala/com/criteo/cuttle/Utils.scala @@ -142,7 +142,7 @@ package object utils { .evalMap[IO, Option[A]](_ => IO.shift.flatMap(_ => thunk)) .flatMap({ case Some(x) => Stream(x) - case None => Stream.raiseError[IO](sys.error("Could not get result to stream")) + case None => Stream.raiseError[IO](new RuntimeException("Could not get result to stream")) }) .changes .evalMap[IO, Json](r => encode(r)) diff --git a/cron/src/main/scala/com/criteo/cuttle/cron/CronScheduler.scala b/cron/src/main/scala/com/criteo/cuttle/cron/CronScheduler.scala index a569fecae..3df607944 100644 --- a/cron/src/main/scala/com/criteo/cuttle/cron/CronScheduler.scala +++ b/cron/src/main/scala/com/criteo/cuttle/cron/CronScheduler.scala @@ -1,7 +1,5 @@ package com.criteo.cuttle.cron -import java.time.Instant - import scala.concurrent.stm.Txn.ExternalDecider import scala.concurrent.stm._ import cats.effect.IO