fix warning (?)

zio · Nov 11, 2023 · e33c0a6 · e33c0a6
1 parent 19ac789
commit e33c0a6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/modules/redis/src/main/scala/zio/redis/internal/ClusterExecutor.scala b/modules/redis/src/main/scala/zio/redis/internal/ClusterExecutor.scala
@@ -49,11 +49,11 @@ private[redis] final class ClusterExecutor private (
         res      <- toG(executor.execute(command))
       } yield res
 
-    def executeSafe(keySlot: Slot) = {
+    def executeSafe(keySlot: Slot): IO[RedisError,RespValue] = {
       val recover = execute(keySlot).flatMap {
         case e: RespValue.Error => ZIO.fail(e.asRedisError)
         case success            => ZIO.succeed(success)
-      }.catchSome {
+      }.catchSome[Any, RedisError, RespValue] {
         case e: RedisError.Ask   => executeAsk(e.address)
         case _: RedisError.Moved => refreshConnect *> execute(keySlot)
       }