andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-04-16 07:52:39 +00:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

fix: add _write_lock to reset() and optimize() for batch atomicity

Browse Source
This commit is contained in:
Greyson LaLonde
2026-03-10 22:55:10 -04:00
parent 1bc92ebb5f
commit a037ade1ca
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/crewai/src/crewai/memory/storage/lancedb_storage.py
View File

@@ -612,7 +612,7 @@ class LanceDBStorage:
return info.record_count
def reset(self, scope_prefix: str | None = None) -> None:
with self._file_lock():
with self._write_lock, self._file_lock():
if scope_prefix is None or scope_prefix.strip("/") == "":
if self._table is not None:
self._db.drop_table(self._table_name)
@@ -636,7 +636,7 @@ class LanceDBStorage:
"""
if self._table is None:
return
with self._file_lock():
with self._write_lock, self._file_lock():
self._table.optimize()
self._ensure_scope_index()