File tree Expand file tree Collapse file tree 2 files changed +4
-14
lines changed
compiler/base/orchestrator/src Expand file tree Collapse file tree 2 files changed +4
-14
lines changed Original file line number Diff line number Diff line change @@ -2430,15 +2430,8 @@ impl Commander {
2430
2430
}
2431
2431
2432
2432
Gc => {
2433
- waiting = mem:: take ( & mut waiting)
2434
- . into_iter ( )
2435
- . filter ( |( _job_id, tx) | !tx. is_closed ( ) )
2436
- . collect ( ) ;
2437
-
2438
- waiting_once = mem:: take ( & mut waiting_once)
2439
- . into_iter ( )
2440
- . filter ( |( _job_id, tx) | !tx. is_closed ( ) )
2441
- . collect ( ) ;
2433
+ waiting. retain ( |_job_id, tx| !tx. is_closed ( ) ) ;
2434
+ waiting_once. retain ( |_job_id, tx| !tx. is_closed ( ) ) ;
2442
2435
}
2443
2436
}
2444
2437
}
Original file line number Diff line number Diff line change @@ -15,7 +15,6 @@ use snafu::prelude::*;
15
15
use std:: {
16
16
collections:: BTreeMap ,
17
17
convert:: TryFrom ,
18
- mem,
19
18
pin:: pin,
20
19
sync:: {
21
20
atomic:: { AtomicU64 , Ordering } ,
@@ -470,10 +469,8 @@ async fn handle_core(
470
469
}
471
470
472
471
GarbageCollection => {
473
- active_executions = mem:: take ( & mut active_executions)
474
- . into_iter ( )
475
- . filter ( |( _id, ( _, tx) ) | tx. as_ref ( ) . is_some_and ( |tx| !tx. is_closed ( ) ) )
476
- . collect ( ) ;
472
+ active_executions
473
+ . retain ( |_id, ( _, tx) | tx. as_ref ( ) . is_some_and ( |tx| !tx. is_closed ( ) ) ) ;
477
474
}
478
475
479
476
IdleTimeout | IdleRequest => {
You can’t perform that action at this time.
0 commit comments