GH #131: Do not cache version twice

evolution-gaming · Dec 28, 2020 · 41369fc · 41369fc
1 parent 5bc8b1d
commit 41369fc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...e-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraModule.scala b/...e-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraModule.scala
@@ -57,8 +57,7 @@ object CassandraModule {
       // `syncSession` is `keyspaceSession` if `autoCreate` was disabled,
       // no need to reconnect
       unsafeSession   <- if (keyspace.autoCreate) keyspaceSession else Resource.liftF(syncSession.pure[F])
-      plainSession    <- SafeSession.of(unsafeSession)
-      _session        <- plainSession.cachePrepared
+      _session        <- SafeSession.of(unsafeSession)
       _healthCheck    <- CassandraHealthCheckOf(unsafeSession, config)
     } yield new CassandraModule[F] {
       def session  = _session