Common streams 0.3.0

snowplow-incubator · Jan 15, 2024 · 565c94a · 565c94a
1 parent c8cec39
commit 565c94a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 106 deletions.
diff --git a/...les/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala b/...les/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._

diff --git a/...es/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Coldswap.scala b/...es/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Coldswap.scala
diff --git a/modules/core/src/test/scala/com.snowplowanalytics.snowplow.snowflake/MockEnvironment.scala b/modules/core/src/test/scala/com.snowplowanalytics.snowplow.snowflake/MockEnvironment.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

diff --git a/project/Dependencies.scala b/project/Dependencies.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"
 
     // tests
     val specs2           = "4.20.0"