@@ -529,7 +529,7 @@ extension Actions {
529
529
return item
530
530
}
531
531
532
- private static func run( _ query: Query , shouldRetry: Int = 5 , asSubQuery : Bool = false ) async throws {
532
+ private static func run( _ query: Query , shouldRetry: Int = 5 ) async throws {
533
533
func retryOrFail( _ message: String ) async throws {
534
534
if shouldRetry > 1 {
535
535
log ( level: . verbose, " [* \( query. name) *] \( message) " )
@@ -548,10 +548,6 @@ extension Actions {
548
548
return nil
549
549
}
550
550
551
- if shouldRetry == 5 , !asSubQuery {
552
- log ( " [* \( query. name) *] Fetching " )
553
- }
554
-
555
551
let info : Data
556
552
do {
557
553
let Q = query. queryText
@@ -601,11 +597,20 @@ extension Actions {
601
597
try await run ( extraQueries, asSubQueries: true )
602
598
}
603
599
604
- private static func run( _ queries: Lista < Query > , asSubQueries: Bool = false ) async throws {
600
+ private static var lastRunTitle = " "
601
+ private static func run( _ queries: Lista < Query > , asSubQueries _: Bool = false ) async throws {
602
+ guard let firstQuery = queries. first else {
603
+ return
604
+ }
605
+ let title = " [* \( firstQuery. name) *] Fetching "
606
+ if lastRunTitle != title {
607
+ lastRunTitle = title
608
+ log ( title)
609
+ }
605
610
try await withThrowingTaskGroup ( of: Void . self) { group in
606
611
for query in queries {
607
612
group. addTask {
608
- try await run ( query, asSubQuery : asSubQueries )
613
+ try await run ( query)
609
614
}
610
615
}
611
616
try await group. waitForAll ( )
0 commit comments