Skip to content

Commit ccfac09

Browse files
authored
Merge 43ba7da into d84e4ee
2 parents d84e4ee + 43ba7da commit ccfac09

File tree

1 file changed

+2
-9
lines changed
  • core/scheduler/src/main/scala/org/apache/openwhisk/core/scheduler/queue

1 file changed

+2
-9
lines changed

core/scheduler/src/main/scala/org/apache/openwhisk/core/scheduler/queue/MemoryQueue.scala

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1218,17 +1218,10 @@ object MemoryQueue {
12181218
s"[$invocationNamespace:$action:$stateName] some activations are stale msg: ${queue.head.msg.activationId}.")
12191219
val timeSinceLastActivationGrabbed = clock.now().toEpochMilli - lastActivationExecutedTime.get()
12201220
if (timeSinceLastActivationGrabbed > maxRetentionMs && timeSinceLastActivationGrabbed > actionMetaData.limits.timeout.millis) {
1221-
MetricEmitter.emitGaugeMetric(
1221+
MetricEmitter.emitCounterMetric(
12221222
LoggingMarkers
1223-
.SCHEDULER_QUEUE_NOT_PROCESSING(invocationNamespace, action.asString, action.toStringWithoutVersion),
1224-
1)
1225-
} else {
1226-
MetricEmitter.emitGaugeMetric(
1227-
LoggingMarkers
1228-
.SCHEDULER_QUEUE_NOT_PROCESSING(invocationNamespace, action.asString, action.toStringWithoutVersion),
1229-
0)
1223+
.SCHEDULER_QUEUE_NOT_PROCESSING(invocationNamespace, action.asString, action.toStringWithoutVersion))
12301224
}
1231-
12321225
queueRef ! DropOld
12331226
}
12341227
}

0 commit comments

Comments
 (0)