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 1dddabf wip
1dddabf is described below
commit 1dddabf1c4e5b3f9dd0e3ec6749e8eb6277339da
Author: Nicolas Vollmar <[email protected]>
AuthorDate: Tue Aug 22 14:12:21 2023 +0200
wip
---
.../apache/pekko/persistence/cassandra/query/EventsByTagSpec.scala | 6 +++---
1 file changed, 3 insertions(+), 3 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 251e353..1a68891 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,7 +108,7 @@ 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 = 1s
+ new-persistence-id-scan-timeout = 1.5s
cleanup-old-persistence-ids = 2s
back-track {
// need to be smaller than the cleanup old persistence ids
@@ -1360,7 +1360,7 @@ object EventsByTagDisabledSpec {
class EventsByTagPersistenceIdCleanupSpec extends
AbstractEventsByTagSpec(EventsByTagSpec.persistenceIdCleanupConfig) {
- private val newPersistenceIdScan: FiniteDuration = 1.second
+ private val newPersistenceIdScan: FiniteDuration = 1.5.second
private val cleanupPeriod: FiniteDuration = 2.second
private val logFilters = Set("cleanup-old-persistence-ids has been set")
@@ -1391,7 +1391,7 @@ class EventsByTagPersistenceIdCleanupSpec extends
AbstractEventsByTagSpec(Events
writeTaggedEvent(event2, Set("cleanup-tag"), 2, bucketSize)
// we don't now when exactly the next persistence id scan will be
- probe.expectNoMessage(newPersistenceIdScan - 150.millis)
+ probe.expectNoMessage(newPersistenceIdScan - 500.millis)
probe.expectNextPF { case e @ EventEnvelope(_, "cleanup", 2L,
"cleanup-2") => e }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
