From 5dcf79233e8dc6ceb7a3f7004a4a0c0e3d2c428c Mon Sep 17 00:00:00 2001 From: Mubelotix Date: Wed, 23 Jul 2025 11:30:39 +0200 Subject: [PATCH] Remove useless parameter Co-Authored-By: Tamo --- .../src/scheduler/process_snapshot_creation.rs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs b/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs index b9c4329ff..0859974cc 100644 --- a/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs +++ b/crates/index-scheduler/src/scheduler/process_snapshot_creation.rs @@ -18,12 +18,11 @@ use crate::{Error, IndexScheduler, Result}; unsafe fn mark_tasks_as_succeeded( tasks: &[Task], dst: &std::path::Path, - nb_db: u32, index_base_map_size: usize, ) -> Result<()> { let env_options = EnvOpenOptions::new(); let mut env_options = env_options.read_txn_without_tls(); - let env = env_options.max_dbs(nb_db).map_size(index_base_map_size).open(dst)?; + let env = env_options.max_dbs(TaskQueue::nb_db()).map_size(index_base_map_size).open(dst)?; let mut wtxn = env.write_txn()?; let task_queue = TaskQueue::new(&env, &mut wtxn)?; for mut task in tasks.iter().cloned() { @@ -84,7 +83,6 @@ impl IndexScheduler { mark_tasks_as_succeeded( &tasks, &dst, - Self::nb_db(), self.index_mapper.index_base_map_size, )?; }