mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 19:31:51 +08:00
enhance: remove unnecessary sleep in query and upsert test cases (#43102)
remove unnecessary sleep in query and upsert test cases https://github.com/milvus-io/milvus/issues/36995 Signed-off-by: Xianhui.Lin <xianhui.lin@zilliz.com>
This commit is contained in:
parent
e97e44d56e
commit
ee053fa244
@ -503,7 +503,6 @@ func TestQueryJsonDynamicExpr(t *testing.T) {
|
||||
prepare.InsertData(ctx, t, mc, hp.NewInsertParams(schema), hp.TNewDataOption())
|
||||
prepare.CreateIndex(ctx, t, mc, hp.TNewIndexParams(schema))
|
||||
prepare.Load(ctx, t, mc, hp.NewLoadParams(schema.CollectionName))
|
||||
time.Sleep(400 * time.Millisecond)
|
||||
// query with different expr and count
|
||||
expr := fmt.Sprintf("%s['number'] < 10 || %s < 10", common.DefaultJSONFieldName, common.DefaultDynamicNumberField)
|
||||
|
||||
@ -553,7 +552,6 @@ func TestQueryCountJsonDynamicExpr(t *testing.T) {
|
||||
prepare.InsertData(ctx, t, mc, hp.NewInsertParams(schema), hp.TNewDataOption())
|
||||
prepare.CreateIndex(ctx, t, mc, hp.TNewIndexParams(schema))
|
||||
prepare.Load(ctx, t, mc, hp.NewLoadParams(schema.CollectionName))
|
||||
time.Sleep(400 * time.Millisecond)
|
||||
// query with different expr and count
|
||||
type exprCount struct {
|
||||
expr string
|
||||
@ -1086,7 +1084,6 @@ func TestQueryWithTemplateParam(t *testing.T) {
|
||||
prepare.InsertData(ctx, t, mc, hp.NewInsertParams(schema), hp.TNewDataOption())
|
||||
prepare.CreateIndex(ctx, t, mc, hp.TNewIndexParams(schema))
|
||||
prepare.Load(ctx, t, mc, hp.NewLoadParams(schema.CollectionName))
|
||||
time.Sleep(400 * time.Millisecond)
|
||||
// query
|
||||
int64Values := make([]int64, 0, 1000)
|
||||
for i := 10; i < 10+1000; i++ {
|
||||
@ -1158,7 +1155,6 @@ func TestQueryWithTemplateParamInvalid(t *testing.T) {
|
||||
prepare.InsertData(ctx, t, mc, hp.NewInsertParams(schema), hp.TNewDataOption())
|
||||
prepare.CreateIndex(ctx, t, mc, hp.TNewIndexParams(schema))
|
||||
prepare.Load(ctx, t, mc, hp.NewLoadParams(schema.CollectionName))
|
||||
time.Sleep(400 * time.Millisecond)
|
||||
// query with invalid template
|
||||
// expr := "varchar like 'a%' "
|
||||
_, err2 := mc.Query(ctx, client.NewQueryOption(schema.CollectionName).WithFilter("varchar like {key1}").WithTemplateParam("key1", "'a%'"))
|
||||
|
||||
@ -488,7 +488,6 @@ func TestUpsertDynamicField(t *testing.T) {
|
||||
prepare.InsertData(ctx, t, mc, hp.NewInsertParams(schema), hp.TNewDataOption())
|
||||
prepare.CreateIndex(ctx, t, mc, hp.TNewIndexParams(schema))
|
||||
prepare.Load(ctx, t, mc, hp.NewLoadParams(schema.CollectionName))
|
||||
time.Sleep(time.Second * 4)
|
||||
// verify that dynamic field exists
|
||||
upsertNb := 10
|
||||
resSet, err := mc.Query(ctx, client.NewQueryOption(schema.CollectionName).WithFilter(fmt.Sprintf("%s < %d", common.DefaultDynamicNumberField, upsertNb)).
|
||||
@ -514,7 +513,6 @@ func TestUpsertDynamicField(t *testing.T) {
|
||||
dynamicColumns := hp.GenDynamicColumnData(common.DefaultNb, upsertNb)
|
||||
_, err = mc.Upsert(ctx, client.NewColumnBasedInsertOption(schema.CollectionName).WithColumns(pkColumn2, vecColumn2).WithColumns(dynamicColumns...))
|
||||
common.CheckErr(t, err, true)
|
||||
time.Sleep(time.Second * 4)
|
||||
// query and gets dynamic field
|
||||
resSet, err = mc.Query(ctx, client.NewQueryOption(schema.CollectionName).WithFilter(fmt.Sprintf("%s >= %d", common.DefaultDynamicNumberField, common.DefaultNb)).
|
||||
WithOutputFields(common.DefaultDynamicFieldName).WithConsistencyLevel(entity.ClStrong))
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user