mirror of
https://github.com/BerriAI/litellm.git
synced 2026-09-25 01:02:15 +00:00
fix(cache-redis-semantic): isolate on an incompatible index after a lost create race
Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
This commit is contained in:
parent
974d9f97ff
commit
6237dd51cb
1 changed files with 8 additions and 8 deletions
|
|
@ -70,14 +70,14 @@ impl Inner {
|
|||
let name = match index_compatible(connection, &self.index_name, dims)? {
|
||||
Some(true) => self.index_name.clone(),
|
||||
Some(false) => self.isolated_index(connection, dims)?,
|
||||
None => {
|
||||
if create_index(connection, &self.index_name, dims).is_err()
|
||||
&& index_compatible(connection, &self.index_name, dims)? != Some(true)
|
||||
{
|
||||
return Err(Error::Unavailable);
|
||||
}
|
||||
self.index_name.clone()
|
||||
}
|
||||
None => match create_index(connection, &self.index_name, dims) {
|
||||
Ok(()) => self.index_name.clone(),
|
||||
Err(_) => match index_compatible(connection, &self.index_name, dims)? {
|
||||
Some(true) => self.index_name.clone(),
|
||||
Some(false) => self.isolated_index(connection, dims)?,
|
||||
None => return Err(Error::Unavailable),
|
||||
},
|
||||
},
|
||||
};
|
||||
let _ = self.resolved_index.set(name.clone());
|
||||
Ok(name)
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue