Skip to content

Commit 0205d2e

Browse files
Fix rebase errors
1 parent 9fad6e3 commit 0205d2e

File tree

4 files changed

+15
-3
lines changed

4 files changed

+15
-3
lines changed

common/scala/src/main/scala/org/apache/openwhisk/core/WarmUp.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ object WarmUp {
4141
revision = DocRevision.empty,
4242
user = warmUpActionIdentity,
4343
activationId = new ActivationIdGenerator {}.make(),
44+
DocId(warmUpAction.asString),
4445
rootControllerIndex = controller,
4546
blocking = false,
4647
content = None,
@@ -54,6 +55,7 @@ object WarmUp {
5455
val metadata = WhiskActionMetaData(
5556
warmUpAction.path,
5657
warmUpAction.name,
58+
DocId(warmUpAction.asString),
5759
CodeExecMetaDataAsString(manifest, false, entryPoint = None))
5860
ContainerCreationMessage(
5961
TransactionId.warmUp,

tests/src/test/scala/org/apache/openwhisk/core/invoker/test/ContainerMessageConsumerTests.scala

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,7 @@ class ContainerMessageConsumerTests
157157
sendAckToScheduler(producer))
158158

159159
val exec = CodeExecAsString(RuntimeManifest("nodejs:10", ImageName("testImage")), "testCode", None)
160+
val docId = DocId("testns/[email protected]")
160161
val action =
161162
WhiskAction(EntityPath("testns"), EntityName("testAction"), exec, limits = ActionLimits(TimeLimit(1.minute)))
162163
put(entityStore, action)
@@ -166,6 +167,7 @@ class ContainerMessageConsumerTests
166167
WhiskActionMetaData(
167168
action.namespace,
168169
action.name,
170+
docId,
169171
execMetadata,
170172
action.parameters,
171173
action.limits,
@@ -212,6 +214,7 @@ class ContainerMessageConsumerTests
212214
sendAckToScheduler(ackConsumer.getProducer()))
213215

214216
val exec = CodeExecAsString(RuntimeManifest("nodejs:10", ImageName("testImage")), "testCode", None)
217+
val docId = DocId("testns/[email protected]")
215218
val whiskAction =
216219
WhiskAction(EntityPath("testns"), EntityName("testAction2"), exec, limits = ActionLimits(TimeLimit(1.minute)))
217220
val execMetadata =
@@ -220,6 +223,7 @@ class ContainerMessageConsumerTests
220223
WhiskActionMetaData(
221224
whiskAction.namespace,
222225
whiskAction.name,
226+
docId,
223227
execMetadata,
224228
whiskAction.parameters,
225229
whiskAction.limits,
@@ -294,14 +298,15 @@ class ContainerMessageConsumerTests
294298
WarmUp.warmUpAction.name,
295299
exec,
296300
limits = ActionLimits(TimeLimit(1.minute)))
297-
val doc = put(entityStore, action)
301+
val docId = DocId(action.fullyQualifiedName(true).asString)
298302
val execMetadata =
299303
CodeExecMetaDataAsString(exec.manifest, entryPoint = exec.entryPoint)
300304

301305
val actionMetadata =
302306
WhiskActionMetaData(
303307
action.namespace,
304308
action.name,
309+
docId,
305310
execMetadata,
306311
action.parameters,
307312
action.limits,

tests/src/test/scala/org/apache/openwhisk/core/loadBalancer/test/ShardingContainerPoolBalancerTests.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ import scala.concurrent.Future
3939
import scala.concurrent.duration._
4040
import org.apache.openwhisk.common.Logging
4141
import org.apache.openwhisk.common.NestedSemaphore
42+
import org.apache.openwhisk.common.InvokerHealth
4243
import org.apache.openwhisk.core.entity._
4344
import org.apache.openwhisk.common.TransactionId
4445
import org.apache.openwhisk.core.WhiskConfig

tests/src/test/scala/org/apache/openwhisk/core/scheduler/container/test/ContainerManagerTests.scala

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,12 +91,14 @@ class ContainerManagerTests
9191
val resourcesStrictPolicy = false
9292

9393
val exec = CodeExecAsString(RuntimeManifest("actionKind", ImageName("testImage")), "testCode", None)
94-
val action = ExecutableWhiskAction(EntityPath(testNamespace), EntityName(testAction), exec)
94+
val docId = DocId(s"$testNamespace/$testAction@0.0.1")
95+
val action = ExecutableWhiskAction(EntityPath(testNamespace), EntityName(testAction), docId, exec)
9596
val execMetadata = CodeExecMetaDataAsString(exec.manifest, entryPoint = exec.entryPoint)
9697
val actionMetadata =
9798
WhiskActionMetaData(
9899
action.namespace,
99100
action.name,
101+
docId,
100102
execMetadata,
101103
action.parameters,
102104
action.limits,
@@ -776,12 +778,14 @@ class ContainerManagerTests
776778
ContainerManager.props(factory(mockJobManager), mockMessaging(), testsid, mockEtcd, config, mockWatcher.ref))
777779

778780
val exec = BlackBoxExec(ExecManifest.ImageName("image"), None, None, native = false, binary = false)
779-
val action = ExecutableWhiskAction(EntityPath(testNamespace), EntityName(testAction), exec)
781+
val docId = DocId(s"$testNamespace/$testAction@0.0.1")
782+
val action = ExecutableWhiskAction(EntityPath(testNamespace), EntityName(testAction), docId, exec)
780783
val execMetadata = BlackBoxExecMetaData(exec.image, exec.entryPoint, exec.native, exec.binary)
781784
val actionMetadata =
782785
WhiskActionMetaData(
783786
action.namespace,
784787
action.name,
788+
docId,
785789
execMetadata,
786790
action.parameters,
787791
action.limits,

0 commit comments

Comments
 (0)