upstream-archive/qdrant
1
0
Fork 0
mirror of https://github.com/qdrant/qdrant.git synced 2026-07-23 11:11:00 -05:00
Code Issues Packages Projects Releases Wiki Activity

test: stabilize test_payload_strict_mode_upsert_no_local_shard (#8973)

Browse Source 
Use unique point IDs across all phases instead of overwriting the same
id repeatedly. The gridstore payload storage size estimate is
bitmask-based: overwrites keep old blocks allocated until a periodic
flush reclaims them, so the test was racing the 5s flush worker. With
unique ids every block stays live and the post-flush size still
reflects all inserted points.

Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
Andrey Vasnetsov
2026-05-10 00:28:39 +02:00
committed by generall
parent bd4aab364e
commit b91e7bceda
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
tests/consensus_tests/test_strict_mode.py
View File

@@ -164,8 +164,13 @@ def test_payload_strict_mode_upsert_no_local_shard(tmp_path: pathlib.Path):
payload = {"country": "Germany", "city": "Berlin"}
for _ in range(32):
point = {"id": 1, "payload": payload, "vector": random_dense_vector()}
# Use unique point IDs across all phases. The mmap (gridstore) payload
# storage size estimate is bitmask-based: overwriting the same id keeps
# old blocks allocated until a periodic flush reclaims them, which makes
# a same-id test race the flush worker. Unique ids keep every block live,
# so the post-flush size still reflects all inserted points.
for i in range(32):
point = {"id": i, "payload": payload, "vector": random_dense_vector()}
upsert_points(peer_urls[0], [point], collection_name=COLLECTION_NAME, shard_key="non_leader").raise_for_status()
set_strict_mode(peer_urls[0], COLLECTION_NAME, {
@@ -175,12 +180,12 @@ def test_payload_strict_mode_upsert_no_local_shard(tmp_path: pathlib.Path):
wait_for_strict_mode_enabled(peer_urls[1], COLLECTION_NAME)
for _ in range(32):
point = {"id": 2, "payload": payload, "vector": random_dense_vector()}
for i in range(32, 64):
point = {"id": i, "payload": payload, "vector": random_dense_vector()}
upsert_points(peer_urls[0], [point], collection_name=COLLECTION_NAME, shard_key="non_leader").raise_for_status()
for _ in range(32):
point = {"id": 3, "payload": payload, "vector": random_dense_vector()}
for i in range(64, 96):
point = {"id": i, "payload": payload, "vector": random_dense_vector()}
res = upsert_points(peer_urls[0], [point], collection_name=COLLECTION_NAME, shard_key="non_leader")
if not res.ok:
assert "Max payload storage size" in res.json()['status']['error']