Skip to content

Commit 6b1481f

Browse files
Make testcase stable
1 parent 06ed0bb commit 6b1481f

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

tests/src/test/scala/org/apache/openwhisk/core/containerpool/v2/test/FunctionPullingContainerProxyTests.scala

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1360,9 +1360,10 @@ class FunctionPullingContainerProxyTests
13601360
val (client, clientFactory) = testClient
13611361
val instanceId = InvokerInstanceId(0, userMemory = defaultUserMemory)
13621362

1363+
val pool = TestProbe()
13631364
val probe = TestProbe()
13641365
val machine =
1365-
probe.childActorOf(
1366+
pool.childActorOf(
13661367
FunctionPullingContainerProxy
13671368
.props(
13681369
factory,
@@ -1399,7 +1400,7 @@ class FunctionPullingContainerProxyTests
13991400
""))
14001401

14011402
probe.expectMsg(Transition(machine, CreatingClient, ClientCreated))
1402-
expectInitialized(probe)
1403+
expectInitialized(pool)
14031404
client.expectMsg(RequestActivation())
14041405
client.send(machine, message)
14051406

@@ -1412,7 +1413,7 @@ class FunctionPullingContainerProxyTests
14121413
machine ! StateTimeout
14131414
client.send(machine, RetryRequestActivation)
14141415
probe.expectMsg(Transition(machine, Running, Pausing))
1415-
probe.expectMsgType[ContainerIsPaused]
1416+
pool.expectMsgType[ContainerIsPaused]
14161417
dataManagementService.expectMsgAllOf(
14171418
RegisterData(
14181419
ContainerKeys
@@ -1440,10 +1441,9 @@ class FunctionPullingContainerProxyTests
14401441
Some(instanceId),
14411442
Some(testContainerId)),
14421443
""))
1443-
inAnyOrder {
1444-
probe.expectMsg(Transition(machine, Paused, Running))
1445-
probe.expectMsgType[Resumed]
1446-
}
1444+
1445+
probe.expectMsg(Transition(machine, Paused, Running))
1446+
pool.expectMsgType[Resumed]
14471447

14481448
awaitAssert {
14491449
factory.calls should have size 1

0 commit comments

Comments
 (0)