upgrade the localstack version

explicitly create and delete kinesis stream for tests
laserdisc-io · Nov 21, 2023 · f987d12 · f987d12
1 parent 4884dca
commit f987d12
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -22,7 +22,7 @@ services:
       exit 0;
       "
   localstack:
-    image: localstack/localstack:1.2.0
+    image: localstack/localstack:3
     ports:
       - 4566:4566
     environment:

diff --git a/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala b/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala
@@ -90,7 +90,7 @@ class NewLocalStackSuite extends AnyFlatSpec with Matchers with ScalaFutures {
 
     val data = List("foo", "bar", "baz")
 
-    val test = kAlgebraResource(kac, dac, cac).use { case (_, kAlgebra) =>
+    val test = kAlgebraResource(kac, dac, cac).use { case (ki, kAlgebra) =>
       for {
         _ <- Stream
           .emits(data)
@@ -207,6 +207,9 @@ class NewLocalStackSuite extends AnyFlatSpec with Matchers with ScalaFutures {
       k <- i.KinesisAsyncClientResource(kac)
       kinesisInterpreter = i.create(k)
       kAlgebra           = Kinesis.create[IO](k, d, c)
+      _ <- Resource.make(
+        kinesisInterpreter.createStream(CreateStreamRequest.builder().streamName("test").build())
+      )(_ => kinesisInterpreter.deleteStream(DeleteStreamRequest.builder().streamName("test").build()).void)
     } yield kinesisInterpreter -> kAlgebra
 
 }