Use a new method.

evolution-gaming · Feb 28, 2024 · 40040e7 · 40040e7
1 parent 3866871
commit 40040e7
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/...dra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SetupSchema.scala b/...dra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SetupSchema.scala
@@ -5,7 +5,7 @@ import cats.effect.kernel.Temporal
 import cats.syntax.all._
 import cats.{MonadThrow, Parallel}
 import com.evolutiongaming.catshelper.LogOf
-import com.evolutiongaming.kafka.journal.cassandra.{CassandraSync => CassandraSync2, MigrateSchema, SettingsCassandra}
+import com.evolutiongaming.kafka.journal.cassandra.{MigrateSchema, SettingsCassandra}
 import com.evolutiongaming.kafka.journal.{Origin, Settings}
 import com.evolutiongaming.scassandra.ToCql.implicits._
 
@@ -38,10 +38,7 @@ object SetupSchema {
     settings: Settings[F],
     cassandraSync: CassandraSync[F]
   ): F[Unit] = {
-    val cassandraSync2 = new CassandraSync2[F] {
-      def apply[A](fa: F[A]): F[A] = cassandraSync(fa)
-    }
-    val migrateSchema = MigrateSchema.forSettingKey(cassandraSync2, settings, SettingKey, migrations(schema))
+    val migrateSchema = MigrateSchema.forSettingKey(cassandraSync.toCassandraSync2, settings, SettingKey, migrations(schema))
     migrateSchema.run(fresh)
   }