From fc9c00b9d577f1af91d8635a9a2f3bfdabb33824 Mon Sep 17 00:00:00 2001 From: Marcel Coetzee Date: Mon, 13 May 2024 21:54:02 +0200 Subject: [PATCH] Remove unnecessary lock Signed-off-by: Marcel Coetzee --- .../custom_destination_lancedb/custom_destination_lancedb.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py b/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py index 48f737ca86..45f925f051 100644 --- 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)