Johan Andrén
Johan Andrén
Seems it fails to understand that it ends up as exactly the version, rather than a snapshot, first commit after tag probably works around it, but we should make it...
The batching support is super nice, and as far as I understand it you can also achieve that with flows, as long as you emit a `Done` for every element...
References https://github.com/akka/akka-grpc/issues/1939
https://github.com/akka/akka-persistence-r2dbc/actions/runs/8938109475/job/24551597900#step:7:320 ``` --> [akka.persistence.r2dbc.query.EventsBySliceSpec: Current eventsBySlices should read in chunks] Start of log messages of test that [Failed(java.lang.AssertionError: timeout (3 seconds) during expectMessage while waiting for Done)] [2024-05-03 11:22:07,350] [INFO]...
https://github.com/akka/akka-persistence-r2dbc/actions/runs/8784290984/job/24102224672 Full logs [7_sbt test.txt](https://github.com/akka/akka-persistence-r2dbc/files/15063414/7_sbt.test.txt)
With several partitions https://github.com/akka/akka-persistence-r2dbc/actions/runs/8645780675/job/23703666741?pr=541#step:7:971 ``` [info] - must delete events for slice before timestamp *** FAILED *** (116 milliseconds) [info] 0 was not equal to 5 (EventSourcedCleanupSpec.scala:432) [info] org.scalatest.exceptions.TestFailedException: [info]...
https://github.com/akka/akka-persistence-r2dbc/actions/runs/8609321429/job/23593065543#step:6:966 ``` [info] - must delete events for slice before timestamp *** FAILED *** (146 milliseconds) [info] 0 was not equal to 5 (EventSourcedCleanupSpec.scala:432) [info] org.scalatest.exceptions.TestFailedException: [info] at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:392) [info]...
https://github.com/akka/akka-persistence-r2dbc/actions/runs/8378575455/job/22943448331 ``` 76ec0f63a362 Pull complete sqlserver Pulled Network docker_default Creating Network docker_default Created Container sqlserver-db Creating Container sqlserver-db Created Container sqlserver-db Starting Container sqlserver-db Started Container sqlserver-db Waiting Container sqlserver-db...
No point since we are anyway in-process, in `H2Dialect` we do: ``` override def adaptSettings(settings: R2dbcSettings): R2dbcSettings = { val res = settings // app timestamp is db timestamp because...