From 2becfc1f1408819935a056d56cb9bebc99d45d3a Mon Sep 17 00:00:00 2001 From: zhuwenxing Date: Mon, 5 Aug 2024 15:57:55 +0800 Subject: [PATCH] update cdc test Signed-off-by: zhuwenxing --- tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py | 1 + 1 file changed, 1 insertion(+) 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 d20cca209b..48d718a287 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 @@ -223,6 +223,7 @@ class MilvusCDCPerformance: def test_scalability(self, max_duration=600, batch_size=1000, max_concurrency=10): results = [] for concurrency in range(10, max_concurrency + 1, 10): + self.resume_cdc_tasks() logger.info(f"\nTesting with concurrency: {concurrency}") total_time, insert_count, sync_count, insert_throughput, sync_throughput, avg_latency, min_latency, max_latency = self.measure_performance( max_duration, batch_size, concurrency)