Skip to content

Commit 19a3171

Browse files
committed
Apply scalaFmt
1 parent e8a0ab0 commit 19a3171

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

common/scala/src/main/scala/org/apache/openwhisk/common/AverageRingBuffer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ class AverageRingBuffer(private val maxSize: Int) {
3737

3838
def nonEmpty: Boolean = elements.nonEmpty
3939

40-
def average: Double = {
40+
def average: Double = {
4141
val size = elements.size
4242
if (size > 2) {
4343
(sum - max - min) / (size - 2)

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

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,19 @@ import org.apache.openwhisk.core.etcd.EtcdClient
3434
import org.apache.openwhisk.core.etcd.EtcdKV.ContainerKeys.containerPrefix
3535
import org.apache.openwhisk.core.etcd.EtcdKV.{ContainerKeys, QueueKeys, ThrottlingKeys}
3636
import org.apache.openwhisk.core.scheduler.SchedulerEndpoints
37-
import org.apache.openwhisk.core.scheduler.message.{ContainerCreation, ContainerDeletion, FailedCreationJob, SuccessfulCreationJob}
37+
import org.apache.openwhisk.core.scheduler.message.{
38+
ContainerCreation,
39+
ContainerDeletion,
40+
FailedCreationJob,
41+
SuccessfulCreationJob
42+
}
3843
import org.apache.openwhisk.core.scheduler.grpc.{GetActivation, ActivationResponse => GetActivationResponse}
39-
import org.apache.openwhisk.core.scheduler.message.{ContainerCreation, ContainerDeletion, FailedCreationJob, SuccessfulCreationJob}
44+
import org.apache.openwhisk.core.scheduler.message.{
45+
ContainerCreation,
46+
ContainerDeletion,
47+
FailedCreationJob,
48+
SuccessfulCreationJob
49+
}
4050
import org.apache.openwhisk.core.service._
4151
import org.apache.openwhisk.core.{ConfigKeys, WhiskConfig}
4252
import org.apache.openwhisk.http.Messages.{namespaceLimitUnderZero, tooManyConcurrentRequests}
@@ -48,7 +58,7 @@ import scala.annotation.tailrec
4858
import scala.collection.immutable.Queue
4959
import scala.collection.mutable
5060
import scala.concurrent.duration._
51-
import scala.concurrent.{ExecutionContextExecutor, Future, Promise, duration}
61+
import scala.concurrent.{duration, ExecutionContextExecutor, Future, Promise}
5262
import scala.language.postfixOps
5363
import scala.util.{Failure, Success}
5464

0 commit comments

Comments
 (0)