@@ -808,7 +808,6 @@ impl DatabaseQueue for crate::queue::JobQueue<MySql> {
808
808
}
809
809
810
810
async fn get_queue_stats ( & self , queue_name : & str ) -> Result < QueueStats > {
811
- use crate :: job:: JobStatus ;
812
811
use crate :: stats:: JobStatistics ;
813
812
use std:: collections:: HashMap ;
814
813
@@ -825,35 +824,17 @@ impl DatabaseQueue for crate::queue::JobQueue<MySql> {
825
824
counts. insert ( status, count as u64 ) ;
826
825
}
827
826
828
- let pending_count = counts
829
- . get ( "Pending" )
830
- . copied ( )
831
- . unwrap_or ( 0 ) ;
832
- let running_count = counts
833
- . get ( "Running" )
834
- . copied ( )
835
- . unwrap_or ( 0 ) ;
836
- let dead_count = counts
837
- . get ( "Dead" )
838
- . copied ( )
839
- . unwrap_or ( 0 ) ;
840
- let timed_out_count = counts
841
- . get ( "TimedOut" )
842
- . copied ( )
843
- . unwrap_or ( 0 ) ;
844
- let completed_count = counts
845
- . get ( "Completed" )
846
- . copied ( )
847
- . unwrap_or ( 0 ) ;
827
+ let pending_count = counts. get ( "Pending" ) . copied ( ) . unwrap_or ( 0 ) ;
828
+ let running_count = counts. get ( "Running" ) . copied ( ) . unwrap_or ( 0 ) ;
829
+ let dead_count = counts. get ( "Dead" ) . copied ( ) . unwrap_or ( 0 ) ;
830
+ let timed_out_count = counts. get ( "TimedOut" ) . copied ( ) . unwrap_or ( 0 ) ;
831
+ let completed_count = counts. get ( "Completed" ) . copied ( ) . unwrap_or ( 0 ) ;
848
832
849
833
// Basic statistics (more detailed stats would require the statistics collector)
850
834
let statistics = JobStatistics {
851
835
total_processed : completed_count + dead_count,
852
836
completed : completed_count,
853
- failed : counts
854
- . get ( "Failed" )
855
- . copied ( )
856
- . unwrap_or ( 0 ) ,
837
+ failed : counts. get ( "Failed" ) . copied ( ) . unwrap_or ( 0 ) ,
857
838
dead : dead_count,
858
839
timed_out : timed_out_count,
859
840
running : running_count,
0 commit comments