Emcee

1
import Foundation
2
import EmceeLogging
3
import QueueModels
4

5
public final class BucketQueueStateLogger {
6
    private let runningQueueState: RunningQueueState
7
    private let logger: ContextualLogger
8
    
9
    public init(
10
        runningQueueState: RunningQueueState,
11
        logger: ContextualLogger
12
    ) {
13
        self.runningQueueState = runningQueueState
14
        self.logger = logger
15
    }
16
    
17
    public func printQueueSize() {
18
        let dequeuedTests = runningQueueState.dequeuedTests.asDictionary
19
        
20
        let logger = logger.skippingKibana
21
        
22
        for workerId in Array(dequeuedTests.keys).sorted() {
23
            if let testsOnWorker = dequeuedTests[workerId] {
24
                logger.info("\(workerId.value) is executing \(testsOnWorker.map(\.stringValue).sorted().joined(separator: ", "))")
25
            }
26
        }
27

28
        logger.info("Enqueued tests: \(runningQueueState.enqueuedTests.count), running tests: \(runningQueueState.dequeuedTests.flattenValues.count)")
29
    }
30
}
31