diff --git a/storage/aptosdb/src/versioned_node_cache.rs b/storage/aptosdb/src/versioned_node_cache.rs index 8b935f1e77ab1..03f7778e28d83 100644 --- a/storage/aptosdb/src/versioned_node_cache.rs +++ b/storage/aptosdb/src/versioned_node_cache.rs @@ -11,6 +11,7 @@ use std::{ fmt, sync::Arc, }; +use aptos_experimental_runtimes::thread_manager::THREAD_MANAGER; type NodeCache = HashMap; @@ -73,14 +74,16 @@ impl VersionedNodeCache { }; if let Some((version, cache)) = to_evict { - cache - .iter() - .collect::>() - .into_par_iter() - .with_min_len(100) - .for_each(|(node_key, node)| { - lru_cache.put(node_key.clone(), node.clone()); - }); + THREAD_MANAGER.get_non_exe_cpu_pool().install(|| { + cache + .iter() + .collect::>() + .into_par_iter() + .with_min_len(100) + .for_each(|(node_key, node)| { + lru_cache.put(node_key.clone(), node.clone()); + }); + }); let evicted = self.inner.write().pop_front(); assert_eq!(evicted, Some((version, cache)));