fix: ci bug (#272)

zio-spark-core/src/test/scala-2.11/zio/spark/experimental/MapWithEffectSpec.scala

@@ -0,0 +1,7 @@
+package zio.spark.experimental
+
+import zio.test._
+
+object MapWithEffectSpec {
+  def spec = suite("smoke")()
+}

zio-spark-core/src/test/scala-2.12/zio/spark/experimental/MapWithEffectSpec.scala

@@ -0,0 +1,7 @@
+package zio.spark.experimental
+
+import zio.test._
+
+object MapWithEffectSpec {
+  def spec = suite("smoke")()
+}

zio-spark-core/src/test/scala-2.13/zio/spark/experimental/MapWithEffectSpec.scala

@@ -3,15 +3,14 @@ package zio.spark.experimental
 import scala3encoders.given // scalafix:ok
 
 import zio.{Task, ZIO}
-import zio.spark.ZioSparkTestSpec.session
 import zio.spark.experimental.MapWithEffect.RDDOps
 import zio.spark.rdd.RDD
 import zio.spark.sql._
 import zio.spark.sql.implicits._
 import zio.test._
 
-object MapWithEffectSpec extends ZIOSpecDefault {
-  override def spec: Spec[TestEnvironment, Any] =
+object MapWithEffectSpec {
+  def spec: Spec[SparkSession, Throwable] =
     suite("smoke")(
       test("basic smoke test") {
         val getRddInt: SIO[RDD[Int]] = Seq(1, 2, 3).toRDD
@@ -36,5 +35,5 @@ object MapWithEffectSpec extends ZIOSpecDefault {
             assertTrue(size == 10000, i == 1, count.toDouble < (0.95d * size))
           }
       }
-    ).provideLayerShared(session)
+    )
 }

zio-spark-core/src/test/scala-3/zio/spark/experimental/MapWithEffectSpec.scala

@@ -0,0 +1,7 @@
+package zio.spark.experimental
+
+import zio.test._
+
+object MapWithEffectSpec {
+  def spec = suite("smoke")()
+}

zio-spark-core/src/test/scala/zio/spark/ZioSparkTestSpec.scala

@@ -3,7 +3,7 @@ package zio.spark
 import org.apache.log4j.{Level, Logger}
 
 import zio._
-import zio.spark.experimental.{CancellableEffectSpec, PipelineSpec}
+import zio.spark.experimental.{CancellableEffectSpec, MapWithEffectSpec, PipelineSpec}
 import zio.spark.parameter.localAllNodes
 import zio.spark.rdd.{PairRDDFunctionsSpec, RDDSpec}
 import zio.spark.sql.{
@@ -31,7 +31,7 @@ object ZioSparkTestSpec extends ZIOSpecDefault {
   type SparkTestEnvironment = TestEnvironment with SparkSession
   type SparkTestSpec        = Spec[SparkTestEnvironment, Any]
 
-  def spec: Spec[TestEnvironment, Any] = {
+  def spec: Spec[TestEnvironment with Scope, Any] = {
     val specs: Seq[Spec[SparkTestEnvironment, Any]] =
       Seq(
         DatasetSpec.datasetActionsSpec,
@@ -52,9 +52,10 @@ object ZioSparkTestSpec extends ZIOSpecDefault {
         RelationalGroupedDatasetSpec.relationalGroupedDatasetAggregationSpec,
         CancellableEffectSpec.spec,
         StreamingSpec.streamingSpec,
-        DataStreamWriterSpec.dataStreamReaderConfigurationsSpec
+        DataStreamWriterSpec.dataStreamReaderConfigurationsSpec,
+        MapWithEffectSpec.spec
       )
 
-    suite("Spark tests")(specs: _*).provideCustomLayerShared(session)
+    suite("Spark tests")(specs: _*).provideSomeLayerShared[TestEnvironment](session)
   }
 }

zio-spark-core/src/test/scala/zio/spark/rdd/PairRDDFunctionsSpec.scala

@@ -7,7 +7,6 @@ import zio.spark.sql.{Dataset, SparkSession}
 import zio.spark.sql.implicits._
 import zio.test._
 import zio.test.Assertion._
-import zio.test.TestAspect._
 
 object PairRDDFunctionsSpec {
   def spec: Spec[SparkSession, Any] =
@@ -20,5 +19,5 @@ object PairRDDFunctionsSpec {
 
         job.map(assert(_)(equalTo(67L)))
       }
-    ) @@ scala212(ignore)
+    )
 }