17
17
18
18
package org .apache .openwhisk .core .scheduler .queue
19
19
20
- import java .time .{Duration , Instant }
21
- import java .util .concurrent .atomic .AtomicInteger
22
20
import akka .actor .Status .{Failure => FailureMessage }
23
21
import akka .actor .{ActorRef , ActorSystem , Cancellable , FSM , Props , Stash }
24
22
import akka .util .Timeout
25
23
import org .apache .openwhisk .common ._
26
24
import org .apache .openwhisk .core .ConfigKeys
27
25
import org .apache .openwhisk .core .ack .ActiveAck
28
- import org .apache .openwhisk .core .connector .ContainerCreationError .{ TooManyConcurrentRequests , ZeroNamespaceLimit }
26
+ import org .apache .openwhisk .core .connector .ContainerCreationError .ZeroNamespaceLimit
29
27
import org .apache .openwhisk .core .connector ._
30
28
import org .apache .openwhisk .core .containerpool .Interval
31
29
import org .apache .openwhisk .core .database .{NoDocumentException , UserContext }
@@ -44,10 +42,12 @@ import org.apache.openwhisk.core.scheduler.message.{
44
42
import org .apache .openwhisk .core .scheduler .{SchedulerEndpoints , SchedulingConfig }
45
43
import org .apache .openwhisk .core .service ._
46
44
import org .apache .openwhisk .http .Messages .{namespaceLimitUnderZero , tooManyConcurrentRequests }
47
- import pureconfig .generic .auto ._
48
45
import pureconfig .loadConfigOrThrow
49
46
import spray .json ._
47
+ import pureconfig .generic .auto ._
50
48
49
+ import java .time .{Duration , Instant }
50
+ import java .util .concurrent .atomic .AtomicInteger
51
51
import scala .annotation .tailrec
52
52
import scala .collection .immutable .Queue
53
53
import scala .collection .mutable
0 commit comments