From f9bc04fcf77797d220964ba7581a46fc549b2043 Mon Sep 17 00:00:00 2001 From: zhuwenxing Date: Mon, 5 Aug 2024 17:19:21 +0800 Subject: [PATCH] update cdc test Signed-off-by: zhuwenxing --- .../python_client/cdc/perf/milvus_cdc_recovery_perf_test.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 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 9deff01bb1..6df6341a16 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 @@ -136,10 +136,12 @@ class MilvusCDCPerformance: output_fields=["timestamp"], limit=1 ) - break except Exception as e: logger.debug(f"Query failed: {e}") - continue + logger.debug( + f"query latest_insert_ts: {latest_insert_ts}, results: {results} query latency: {time.time()-t0} seconds") + if len(results) > 0 and results[0]["timestamp"] == latest_insert_ts: + break tt = time.time() - t0 # logger.info(f"start to query, latest_insert_ts: {latest_insert_ts}, results: {results}") if len(results) > 0 and results[0]["timestamp"] == latest_insert_ts: