mirror of
https://github.com/lancedb/lancedb.git
synced 2026-11-13 22:26:53 +00:00
A broad documentation pass across the areas LanceDB Enterprise and Embedded diverge on most: **Data Curation** -- GPU Function execution, Slurm scheduling (and what Slurm is, for readers new to it), blob late materialization as its own page, joins, aggregation/profiling, sampling, near-duplicate detection, chunking, distributed shuffle, and IVF-partition clustering. **Feature Engineering** -- computed columns and materialized views, restructured to lead with the Function-based path and show the SQL form side by side with Python throughout; a single Auto Refresh page instead of duplicating scheduling details on every refresh page; adaptive execution; checkpointing; GPU and Slurm placement for refresh workers; a Training Cache page for the PyTorch data loader's automatic cache benefit. **Security & Governance** -- an Audit Log reference (schema, access, grants), Secrets promoted to an ordinary catalog object with their own SQL DDL and a vending/rotation guide, and privilege-table fixes verified against the authorization source. **Deployment & Maintenance** -- Horizontal Scaling and OpenTelemetry moved into a real Deployment area; Automated Cleanup folded into Intelligent Auto-Maintenance (every other maintenance decision already lived there); RTE Compaction and Advanced Conflict Resolution documented in depth. **Landing page** -- the Enterprise feature comparison table reorganized (several redundant or stale rows removed, several new areas added), and the "why Enterprise" bullets replaced with ones tied to a concrete page (Performance, Scale, Fault tolerance, Multicloud deployment, Simplify operations) instead of vague promises. Plus a full pass addressing lancedb-gatekeeper's review: a real test-safety bug (a quickstart test could silently overwrite and delete a deployment's own `frames` table), a fabricated SQL statement with no backing implementation, an actual dedup-guarantee bug in `take_row_ids`, and dozens of documentation-accuracy fixes verified against source rather than taken on faith -- each either fixed, or left with an explicit note on why it needs a feature or deployment owner's sign-off instead of being guessed at. 🤖 Generated with [Claude Code](https://claude.com/claude-code) https://claude.ai/code/session_018PXMCbRH6i5w47TsjeEUMT --------- Co-authored-by: Claude Sonnet 5 <noreply@anthropic.com>
35 lines
1.1 KiB
Python
35 lines
1.1 KiB
Python
# SPDX-License-Identifier: Apache-2.0
|
|
# SPDX-FileCopyrightText: Copyright The LanceDB Authors
|
|
|
|
|
|
def test_read_consistency(tmp_path):
|
|
uri = str(tmp_path)
|
|
# --8<-- [start:read_consistency]
|
|
from datetime import timedelta
|
|
|
|
import lancedb
|
|
|
|
writer = lancedb.connect(uri)
|
|
table = writer.create_table("documents", [{"id": 1, "text": "first"}])
|
|
|
|
default_reader = lancedb.connect(uri).open_table("documents")
|
|
latest_reader = lancedb.connect(
|
|
uri, read_consistency_interval=timedelta(0)
|
|
).open_table("documents")
|
|
|
|
table.add([{"id": 2, "text": "second"}])
|
|
|
|
default_count = default_reader.count_rows()
|
|
latest_count = latest_reader.count_rows()
|
|
print(f"Default reader: {default_count} rows") # 1
|
|
print(f"Zero-interval reader: {latest_count} rows") # 2
|
|
|
|
default_reader.checkout_latest()
|
|
refreshed_count = default_reader.count_rows()
|
|
print(f"After explicit refresh: {refreshed_count} rows") # 2
|
|
# --8<-- [end:read_consistency]
|
|
|
|
assert default_count == 1
|
|
assert latest_count == 2
|
|
assert refreshed_count == 2
|