@@ -2545,7 +2545,7 @@ export class RunQueue {
25452545 return ;
25462546 }
25472547
2548- this . logger . info ( "Processing concurrency keys from stream" , {
2548+ this . logger . debug ( "Processing concurrency keys from stream" , {
25492549 keys : uniqueKeys ,
25502550 } ) ;
25512551
@@ -2615,22 +2615,22 @@ export class RunQueue {
26152615 }
26162616
26172617 private async processCurrentConcurrencyRunIds ( concurrencyKey : string , runIds : string [ ] ) {
2618- this . logger . info ( "Processing concurrency set with runs" , {
2618+ this . logger . debug ( "Processing concurrency set with runs" , {
26192619 concurrencyKey,
2620- runIds : runIds . slice ( 0 , 5 ) , // Log first 5 for debugging,
2620+ runIds : runIds . slice ( 0 , 5 ) ,
26212621 runIdsLength : runIds . length ,
26222622 } ) ;
26232623
26242624 // Call the callback to determine which runs are completed
26252625 const completedRuns = await this . options . concurrencySweeper ?. callback ( runIds ) ;
26262626
26272627 if ( ! completedRuns ) {
2628- this . logger . info ( "No completed runs found in concurrency set" , { concurrencyKey } ) ;
2628+ this . logger . debug ( "No completed runs found in concurrency set" , { concurrencyKey } ) ;
26292629 return ;
26302630 }
26312631
26322632 if ( completedRuns . length === 0 ) {
2633- this . logger . info ( "No completed runs found in concurrency set" , { concurrencyKey } ) ;
2633+ this . logger . debug ( "No completed runs found in concurrency set" , { concurrencyKey } ) ;
26342634 return ;
26352635 }
26362636
0 commit comments