Skip to content

Commit 773822f

Browse files
lancedb table creation fix (#45)
1 parent d4a4339 commit 773822f

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

neumai/neumai/SinkConnectors/LanceDBSink.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ def store(self, vectors_to_store: List[NeumVector]) -> int:
9393
dic[k] = v
9494
data.append(dic)
9595

96-
tbl = db.create_table(table_name, data=data)
96+
tbl = db.create_table(table_name, data=data, mode="overwrite")
9797
if tbl:
9898
return len(tbl.to_pandas())
9999
raise LanceDBInsertionException("LanceDB storing failed. Try later")

0 commit comments

Comments
 (0)