From 7ecc84c89ea9c19a29c760e005b124b88f841481 Mon Sep 17 00:00:00 2001 From: zhuwenxing Date: Tue, 1 Apr 2025 17:50:09 +0800 Subject: [PATCH] update consistency_level Signed-off-by: zhuwenxing --- .../cdc/perf/milvus_cdc_recovery_perf_test.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py b/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py index 8591597a9f..d9e9280fcc 100644 --- a/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py +++ b/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py @@ -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: