File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed
tests/src/test/scala/org/apache/openwhisk/core/scheduler/queue/test Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -547,6 +547,15 @@ class QueueManagerTests
547
547
it should " not skip outdated activation when the revision is older than the one in a datastore" in {
548
548
stream.reset()
549
549
val mockEtcdClient = mock[EtcdClient ]
550
+ (mockEtcdClient
551
+ .get(_ : String ))
552
+ .expects(* )
553
+ .returning(
554
+ Future .successful(
555
+ RangeResponse
556
+ .newBuilder()
557
+ .addKvs(KeyValue .newBuilder().setKey(" test" ).setValue(schedulerEndpoint.serialize).build())
558
+ .build()))
550
559
val dataManagementService = getTestDataManagementService()
551
560
val watcher = TestProbe ()
552
561
@@ -617,7 +626,7 @@ class QueueManagerTests
617
626
QueueManagerConfig (maxRetriesToGetQueue = 2 , maxSchedulingTime = 10 seconds)))
618
627
619
628
queueManager ! activationMessage
620
- Thread .sleep(100 )
629
+ Thread .sleep(1000 )
621
630
(mockEtcdClient.get _) verify (* ) repeated (3 )
622
631
}
623
632
You can’t perform that action at this time.
0 commit comments