This is an automated email from the ASF dual-hosted git repository.
nvollmar pushed a commit to branch fix-tests
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-cassandra.git
The following commit(s) were added to refs/heads/fix-tests by this push:
new 55cab71 wip
55cab71 is described below
commit 55cab71260107b9e04ffe87d1247c744ae0df2bf
Author: Nicolas Vollmar <[email protected]>
AuthorDate: Tue Aug 22 14:41:41 2023 +0200
wip
---
.../pekko/persistence/cassandra/query/EventsByTagSpec.scala | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagSpec.scala
index 1a68891..d641d56 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagSpec.scala
@@ -108,8 +108,8 @@ object EventsByTagSpec {
pekko.persistence.cassandra.events-by-tag {
eventual-consistency-delay = 0s
# will test by requiring a new persistence-id search every 2s
- new-persistence-id-scan-timeout = 1.5s
- cleanup-old-persistence-ids = 2s
+ new-persistence-id-scan-timeout = 2s
+ cleanup-old-persistence-ids = 1s
back-track {
// need to be smaller than the cleanup old persistence ids
period = 1500ms
@@ -1361,7 +1361,7 @@ object EventsByTagDisabledSpec {
class EventsByTagPersistenceIdCleanupSpec extends
AbstractEventsByTagSpec(EventsByTagSpec.persistenceIdCleanupConfig) {
private val newPersistenceIdScan: FiniteDuration = 1.5.second
- private val cleanupPeriod: FiniteDuration = 2.second
+ private val cleanupPeriod: FiniteDuration = 1.second
private val logFilters = Set("cleanup-old-persistence-ids has been set")
@@ -1384,14 +1384,14 @@ class EventsByTagPersistenceIdCleanupSpec extends
AbstractEventsByTagSpec(Events
probe.request(10)
probe.expectNextPF { case e @ EventEnvelope(_, "cleanup", 1L,
"cleanup-1") => e }
// wait for persistence id cleanup
- probe.expectNoMessage(cleanupPeriod + 250.millis)
+ probe.expectNoMessage(cleanupPeriod + 500.millis)
// the metadata for pid cleanup should have been removed meaning the
next event will be delayed
val event2 = PersistentRepr(s"cleanup-2", 2, "cleanup")
writeTaggedEvent(event2, Set("cleanup-tag"), 2, bucketSize)
- // we don't now when exactly the next persistence id scan will be
- probe.expectNoMessage(newPersistenceIdScan - 500.millis)
+ // we don't know when exactly the next persistence id scan will be
+ probe.expectNoMessage(newPersistenceIdScan / 2)
probe.expectNextPF { case e @ EventEnvelope(_, "cleanup", 2L,
"cleanup-2") => e }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
