Skip to content

Commit f5b9c05

Browse files
authored
Merge abc82fc into 60ca660
2 parents 60ca660 + abc82fc commit f5b9c05

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/v2/FunctionPullingContainerProxy.scala

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -611,7 +611,12 @@ class FunctionPullingContainerProxy(
611611
if (runningActivations.isEmpty) {
612612
logging.info(this, s"The Client closed in state: $stateName, action: ${data.action}")
613613
// Stop ContainerProxy(ActivationClientProxy will stop also when send ClientClosed to ContainerProxy).
614-
cleanUp(data.container, None, false)
614+
cleanUp(
615+
data.container,
616+
data.invocationNamespace,
617+
data.action.fullyQualifiedName(withVersion = true),
618+
data.action.rev,
619+
None)
615620
} else {
616621
logging.info(
617622
this,

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -961,7 +961,7 @@ class FunctionPullingContainerProxyTests
961961
}
962962
client.send(machine, ClientClosed)
963963

964-
probe.expectMsgAllOf(ContainerRemoved(false), Transition(machine, Running, Removing))
964+
probe.expectMsgAllOf(ContainerRemoved(true), Transition(machine, Running, Removing))
965965

966966
awaitAssert {
967967
factory.calls should have size 1
@@ -1614,7 +1614,7 @@ class FunctionPullingContainerProxyTests
16141614
client.expectMsg(GracefulShutdown)
16151615
client.send(machine, ClientClosed)
16161616

1617-
probe.expectMsgAllOf(ContainerRemoved(false), Transition(machine, Running, Removing))
1617+
probe.expectMsgAllOf(ContainerRemoved(true), Transition(machine, Running, Removing))
16181618

16191619
awaitAssert {
16201620
factory.calls should have size 1

0 commit comments

Comments
 (0)