mirror of
https://github.com/openai/codex.git
synced 2026-04-24 06:35:50 +00:00
Fixed lint
This commit is contained in:
@@ -647,14 +647,10 @@ impl UnifiedExecSessionManager {
|
||||
pub(crate) async fn terminate_sessions_for_turn(&self, sub_id: &str) {
|
||||
let entries: Vec<SessionEntry> = {
|
||||
let mut sessions = self.session_store.lock().await;
|
||||
let ids: Vec<String> = sessions
|
||||
sessions
|
||||
.sessions
|
||||
.iter()
|
||||
.filter(|(_, entry)| entry.turn_ref.sub_id == sub_id)
|
||||
.map(|(id, _)| id.clone())
|
||||
.collect();
|
||||
ids.into_iter()
|
||||
.filter_map(|id| sessions.remove(&id))
|
||||
.extract_if(|_, entry| entry.turn_ref.sub_id == sub_id)
|
||||
.map(|(_, entry)| entry)
|
||||
.collect()
|
||||
};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user