milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update consistency_level 

Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
cdc_test
zhuwenxing 2025-04-01 17:50:09 +08:00
parent ea20ed80bf
commit 7ecc84c89e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
View File

@ -327,7 +327,7 @@ class MilvusCDCPerformance:
expr=f"timestamp == {latest_insert_ts}",
output_fields=["timestamp"],
limit=1,
consistency_level="Bounded"
consistency_level="Eventually"
)
except Exception as e:
logger.debug(f"Query failed: {e}")
@ -358,7 +358,7 @@ class MilvusCDCPerformance:
expr="",
output_fields=["count(*)"],
timeout=10,
consistency_level="Bounded"
consistency_level="Eventually"
)
tt = time.time() - t0
self.target_count = results[0]['count(*)']
@ -373,7 +373,7 @@ class MilvusCDCPerformance:
expr="",
output_fields=["count(*)"],
timeout=10,
consistency_level="Bounded"
consistency_level="Eventually"
)
tt = time.time() - t0
self.source_count = results[0]['count(*)']
@ -383,7 +383,7 @@ class MilvusCDCPerformance:
previous_count = self.target_collection.query(
expr="",
output_fields=["count(*)"],
consistency_level="Bounded"
consistency_level="Eventually"
)[0]['count(*)']
while not self.stop_query:
try: