Remove unnecessary lock

Signed-off-by: Marcel Coetzee <[email protected]>
dlt-hub · May 13, 2024 · fc9c00b · fc9c00b
1 parent 20e5b31
commit fc9c00b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py b/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py
@@ -115,7 +115,7 @@ def spotify_shows(
 
 @dlt.destination(batch_size=250, name="lancedb")
 def lancedb_destination(items: TDataItems, table: TTableSchema) -> None:
-    db = lancedb.connect(db_path, read_consistency_interval=datetime.timedelta(0))
+    db = lancedb.connect(db_path)
     try:
         tbl = db.open_table(table["name"])
     except FileNotFoundError:
@@ -124,7 +124,7 @@ def lancedb_destination(items: TDataItems, table: TTableSchema) -> None:
 
 
 if __name__ == "__main__":
-    db = lancedb.connect(db_path, read_consistency_interval=datetime.timedelta(0))
+    db = lancedb.connect(db_path)
 
     for show in fields(Shows):
         db.drop_table(show.name, ignore_missing=True)