@@ -680,40 +680,6 @@ describe("ReleaseConcurrencyQueue", () => {
680680 }
681681 } ) ;
682682
683- redisTest (
684- "Should retrieve metrics for all queues via getQueueMetrics" ,
685- async ( { redisContainer } ) => {
686- const { queue } = createReleaseConcurrencyQueue ( redisContainer , 1 ) ;
687-
688- // Set up multiple queues with different states
689- await queue . attemptToRelease ( { name : "metrics-queue1" } , "run1" ) ; // Consume 1 token from queue1
690-
691- // Add more items to queue1 that will be queued due to no tokens
692- await queue . attemptToRelease ( { name : "metrics-queue1" } , "run2" ) ; // This will be queued
693- await queue . attemptToRelease ( { name : "metrics-queue1" } , "run3" ) ; // This will be queued
694- await queue . attemptToRelease ( { name : "metrics-queue1" } , "run4" ) ; // This will be queued
695-
696- const metrics = await queue . getQueueMetrics ( ) ;
697-
698- expect ( metrics ) . toHaveLength ( 1 ) ;
699- expect ( metrics [ 0 ] . releaseQueue ) . toBe ( "metrics-queue1" ) ;
700- expect ( metrics [ 0 ] . currentTokens ) . toBe ( 0 ) ;
701- expect ( metrics [ 0 ] . queueLength ) . toBe ( 3 ) ;
702-
703- // Now add 10 items to 100 different queues
704- for ( let i = 0 ; i < 100 ; i ++ ) {
705- for ( let j = 0 ; j < 10 ; j ++ ) {
706- await queue . attemptToRelease ( { name : `metrics-queue2-${ i } ` } , `run${ i } -${ j } ` ) ;
707- }
708- }
709-
710- const metrics2 = await queue . getQueueMetrics ( ) ;
711- expect ( metrics2 . length ) . toBeGreaterThan ( 90 ) ;
712-
713- await queue . quit ( ) ;
714- }
715- ) ;
716-
717683 redisTest (
718684 "refillTokenIfInReleasings should refill token when releaserId is in the releasings set" ,
719685 async ( { redisContainer } ) => {
0 commit comments