diff --git a/internal/kv/etcd/etcd_kv.go b/internal/kv/etcd/etcd_kv.go index daea9a4dad7076df0ae7c6a4dc0ede524dbb442f..ec1ef457fb56c24adb1fa0e8364ee55b807ae176 100644 --- a/internal/kv/etcd/etcd_kv.go +++ b/internal/kv/etcd/etcd_kv.go @@ -31,7 +31,7 @@ func NewEtcdKV(client *clientv3.Client, rootPath string) *EtcdKV { client: client, rootPath: rootPath, } - go kv.performanceTest(false, 16<<20) + //go kv.performanceTest(false, 16<<20) return kv } @@ -265,6 +265,7 @@ func (kv *EtcdKV) performanceTest(toFile bool, totalBytes int) { tc = time.Since(startT) results.Cases = append(results.Cases, Case{Name: "read", BlockSize: len(data), Speed: 16.0 / tc.Seconds()}) } + kv.RemoveWithPrefix(fmt.Sprintf("performance-rand%d", r)) mb, err := json.Marshal(results) if err != nil { return diff --git a/internal/kv/minio/minio_kv.go b/internal/kv/minio/minio_kv.go index 652471a03ce41324dfe89fc16ab96ebc14c46450..9f8992f7cd9cfc275b461410369e91b47f259d82 100644 --- a/internal/kv/minio/minio_kv.go +++ b/internal/kv/minio/minio_kv.go @@ -76,7 +76,7 @@ func NewMinIOKV(ctx context.Context, option *Option) (*MinIOKV, error) { minioClient: minIOClient, bucketName: option.BucketName, } - go kv.performanceTest(false, 16<<20) + //go kv.performanceTest(false, 16<<20) return kv, nil } @@ -223,6 +223,7 @@ func (kv *MinIOKV) performanceTest(toFile bool, totalBytes int) { tc = time.Since(startT) results.Cases = append(results.Cases, Case{Name: "read", BlockSize: len(data), Speed: 16.0 / tc.Seconds()}) } + kv.RemoveWithPrefix(fmt.Sprintf("performance-rand%d", r)) mb, err := json.Marshal(results) if err != nil { return diff --git a/tests/python_test/requirements.txt b/tests/python_test/requirements.txt index 14ecf9befb36661b63c5725ac18416b4b64bba42..13b2dac197b46dcaa9016ade74f9246a44f4729e 100644 --- a/tests/python_test/requirements.txt +++ b/tests/python_test/requirements.txt @@ -10,7 +10,7 @@ allure-pytest==2.7.0 pytest-print==0.2.1 pytest-level==0.1.1 pytest-xdist==2.2.1 -pymilvus-distributed==0.0.54 +pymilvus-distributed==0.0.55 pytest-rerunfailures==9.1.1 git+https://github.com/Projectplace/pytest-tags ndg-httpsclient