diff --git a/index-scheduler/src/batch.rs b/index-scheduler/src/batch.rs index aaf63ed97..d23a0dbfd 100644 --- a/index-scheduler/src/batch.rs +++ b/index-scheduler/src/batch.rs @@ -661,6 +661,9 @@ impl IndexScheduler { } Batch::IndexCreation { index_uid, primary_key, task } => { let mut wtxn = self.env.write_txn()?; + if self.index_mapper.exists(&wtxn, &index_uid)? { + return Err(Error::IndexAlreadyExists(index_uid)); + } self.index_mapper.create_index(&mut wtxn, &index_uid)?; wtxn.commit()?;