Common streams 0.3.0

Author: pondzix

modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala

@@ -9,6 +9,7 @@ package com.snowplowanalytics.snowplow.snowflake.processing
 
 import cats.effect.{Async, Poll, Resource, Sync}
 import cats.implicits._
+import com.snowplowanalytics.snowplow.runtime.processing.Coldswap
 import com.snowplowanalytics.snowplow.snowflake.{Alert, AppHealth, Config, Monitoring}
 import net.snowflake.ingest.streaming.internal.SnowsFlakePlowInterop
 import net.snowflake.ingest.streaming._

modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Coldswap.scala

@@ -10,9 +10,10 @@ package com.snowplowanalytics.snowplow.snowflake
 import cats.effect.IO
 import cats.effect.kernel.{Ref, Resource, Unique}
 import com.snowplowanalytics.snowplow.runtime.AppInfo
+import com.snowplowanalytics.snowplow.runtime.processing.Coldswap
 import com.snowplowanalytics.snowplow.sinks.Sink
 import com.snowplowanalytics.snowplow.snowflake.AppHealth.Service.{BadSink, Snowflake}
-import com.snowplowanalytics.snowplow.snowflake.processing.{Channel, Coldswap, TableManager}
+import com.snowplowanalytics.snowplow.snowflake.processing.{Channel, TableManager}
 import com.snowplowanalytics.snowplow.sources.{EventProcessingConfig, EventProcessor, SourceAndAck, TokenedEvents}
 import fs2.Stream
 import org.http4s.client.Client

modules/core/src/test/scala/com.snowplowanalytics.snowplow.snowflake/MockEnvironment.scala

@@ -31,7 +31,7 @@ object Dependencies {
     val snappy    = "1.1.10.4" // Version override
 
     // Snowplow
-    val streams = "0.3.0-M2"
+    val streams = "0.3.0-M3"
 
     // tests
     val specs2           = "4.20.0"