diff --git a/src/main/scala/kinesis/mock/cache/Cache.scala b/src/main/scala/kinesis/mock/cache/Cache.scala index 11c12ebe..0d9ea6af 100644 --- a/src/main/scala/kinesis/mock/cache/Cache.scala +++ b/src/main/scala/kinesis/mock/cache/Cache.scala @@ -1242,7 +1242,7 @@ object Cache { )(implicit C: Concurrent[IO], P: Parallel[IO]): IO[Cache] = { val om = new ObjectMapper() - IO(os.exists(config.persistConfig.osPath)).ifM( + IO(os.exists(config.persistConfig.osFile)).ifM( for { jn <- IO(om.readTree(config.persistConfig.osFile.toIO)) streams <- IO.fromEither(jacksonToCirce(jn).as[Streams])