fixing a bug with an unnecessary exception throwing in sse method (#345)

criteo · Jan 15, 2019 · a06e3c2 · a06e3c2
1 parent 73ecc9c
commit a06e3c2
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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